You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by "sriram23kmm (via GitHub)" <gi...@apache.org> on 2023/03/15 11:37:06 UTC
[GitHub] [beam] sriram23kmm opened a new issue, #25849: [Bug]: Illegal to use destination for this producer while using the jmsIO.write with 2.46.0 version
sriram23kmm opened a new issue, #25849:
URL: https://github.com/apache/beam/issues/25849
### What happened?
When we upgraded the Beam version to **2.46.0** to use the **Retryconfiguration** we faced this issue:
JmsIO.Write<String> sink = JmsIO.<String>write()
.withConnectionFactory(ConnectionsFactoryObject)
.withValueMapper(new TextMessageMapper())
.withRetryConfiguration(RetryConfiguration.create(5))
.withQueue("testQueqe");
Here we used the TIBCO for jms
### Issue Priority
Priority: 0 (outage / urgent vulnerability)
### Issue Components
- [ ] Component: Python SDK
- [X] Component: Java SDK
- [ ] Component: Go SDK
- [ ] Component: Typescript SDK
- [X] Component: IO connector
- [ ] Component: Beam examples
- [ ] Component: Beam playground
- [ ] Component: Beam katas
- [ ] Component: Website
- [ ] Component: Spark Runner
- [ ] Component: Flink Runner
- [ ] Component: Samza Runner
- [ ] Component: Twister2 Runner
- [ ] Component: Hazelcast Jet Runner
- [X] Component: Google Cloud Dataflow Runner
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] Abacn commented on issue #25849: [Bug]: Illegal to use destination for this producer while using the jmsIO.write with 2.46.0 version
Posted by "Abacn (via GitHub)" <gi...@apache.org>.
Abacn commented on issue #25849:
URL: https://github.com/apache/beam/issues/25849#issuecomment-1482882746
@sriram23kmm This error is handled and suppressed: https://github.com/apache/beam/blob/ddae966f3346fbe247486324cbf8a8a532895316/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java#L653
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] sriram23kmm commented on issue #25849: [Bug]: Illegal to use destination for this producer while using the jmsIO.write with 2.46.0 version
Posted by "sriram23kmm (via GitHub)" <gi...@apache.org>.
sriram23kmm commented on issue #25849:
URL: https://github.com/apache/beam/issues/25849#issuecomment-1482723374
Getting **Error closing Connection** with jmsIO.read with IBM MQ as jms Queqe
**com.ibm.msg.client.jms.DetailedIllegalStateException: JMSCC0008: This connection is closed.
An application called a method that must not be used after the connection is closed.
Ensure that the connection is not closed before calling the method.**
```
at jdk.internal.reflect.GeneratedConstructorAccessor97.newInstance(Unknown Source)
at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490)
at com.ibm.msg.client.commonservices.j2se.NLSServices.createException(NLSServices.java:319)
at com.ibm.msg.client.commonservices.nls.NLSServices.createException(NLSServices.java:226)
at com.ibm.msg.client.jms.internal.JmsErrorUtils.createException(JmsErrorUtils.java:126)
at com.ibm.msg.client.jms.internal.State.checkNotClosed(State.java:142)
at com.ibm.msg.client.jms.internal.JmsConnectionImpl.getMetaData(JmsConnectionImpl.java:950)
at com.ibm.msg.client.jms.internal.JmsConnectionImpl.stop(JmsConnectionImpl.java:1163)
at com.ibm.mq.jms.MQConnection.stop(MQConnection.java:473)
**at org.apache.beam.sdk.io.jms.JmsIO$UnboundedJmsReader.closeConnection(JmsIO.java:648)
at org.apache.beam.sdk.io.jms.JmsIO$UnboundedJmsReader.lambda$doClose$0(JmsIO.java:635)**
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] Abacn closed issue #25849: [Bug]: Illegal to use destination for this producer while using the jmsIO.write with 2.46.0 version
Posted by "Abacn (via GitHub)" <gi...@apache.org>.
Abacn closed issue #25849: [Bug]: Illegal to use destination for this producer while using the jmsIO.write with 2.46.0 version
URL: https://github.com/apache/beam/issues/25849
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] Abacn commented on issue #25849: [Bug]: Illegal to use destination for this producer while using the jmsIO.write with 2.46.0 version
Posted by "Abacn (via GitHub)" <gi...@apache.org>.
Abacn commented on issue #25849:
URL: https://github.com/apache/beam/issues/25849#issuecomment-1470752734
Thanks for reporting. RetryConfiguration is recently added in #24973. Could you please provide the full exception stacktrace?
we reserve P0 to outage so move the priority for now
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] sriram23kmm commented on issue #25849: [Bug]: Illegal to use destination for this producer while using the jmsIO.write with 2.46.0 version
Posted by "sriram23kmm (via GitHub)" <gi...@apache.org>.
sriram23kmm commented on issue #25849:
URL: https://github.com/apache/beam/issues/25849#issuecomment-1471445843
java.lang.UnsupportedOperationException: Illegal to use destination for this producer
at com.tibco.tibjms.TibjmsMessageProducer._publish(TibjmsMessageProducer.java:198)
at com.tibco.tibjms.TibjmsMessageProducer.send(TibjmsMessageProducer.java:573)
at org.apache.beam.sdk.io.jms.JmsIO$Writer$JmsConnection.publishMessage(JmsIO.java:1035)
at org.apache.beam.sdk.io.jms.JmsIO$Writer$JmsIOProducerFn.publishMessage(JmsIO.java:1118)
at org.apache.beam.sdk.io.jms.JmsIO$Writer$JmsIOProducerFn.processElement(JmsIO.java:1102)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org