[
https://issues.apache.org/jira/browse/CAMEL-23484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on CAMEL-23484 started by Aurélien Pupier.
-----------------------------------------------
> Unstable Paho test EOFException
> -------------------------------
>
> Key: CAMEL-23484
> URL: https://issues.apache.org/jira/browse/CAMEL-23484
> Project: Camel
> Issue Type: Test
> Components: camel-paho
> Affects Versions: 4.20.0
> Reporter: Aurélien Pupier
> Assignee: Aurélien Pupier
> Priority: Minor
>
> 5 tests are failign often on Ci with similar error:
> {noformat}
> org.apache.camel.RuntimeCamelException: Connection lost (32109) -
> java.io.EOFException
> at
> org.apache.camel.RuntimeCamelException.wrapRuntimeException(RuntimeCamelException.java:68)
> at
> org.apache.camel.support.service.BaseService.doFail(BaseService.java:431)
> at
> org.apache.camel.support.service.BaseService.fail(BaseService.java:360)
> at
> org.apache.camel.support.service.BaseService.start(BaseService.java:136)
> at
> org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:127)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.startService(AbstractCamelContext.java:3584)
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRouteConsumers(InternalRouteStartupManager.java:425)
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.doStartRouteConsumers(InternalRouteStartupManager.java:341)
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:217)
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.lambda$doStartOrResumeRoutes$1(InternalRouteStartupManager.java:129)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.lambda$startingRoutes$2(AbstractCamelContext.java:1159)
> at
> org.apache.camel.util.concurrent.ContextValueFactory.where(ContextValueFactory.java:65)
> at
> org.apache.camel.util.concurrent.ContextValue.where(ContextValue.java:174)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.startingRoutes(AbstractCamelContext.java:1157)
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:117)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:3190)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2796)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2751)
> at
> org.apache.camel.support.service.BaseService.start(BaseService.java:123)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2331)
> at
> org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:214)
> at
> org.apache.camel.test.infra.core.DefaultContextLifeCycleManager.beforeEach(DefaultContextLifeCycleManager.java:80)
> at
> org.apache.camel.test.infra.core.DefaultCamelContextExtension.beforeEach(DefaultCamelContextExtension.java:102)
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
> Caused by: Connection lost (32109) - java.io.EOFException
> at
> org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:197)
> at java.base/java.lang.Thread.run(Thread.java:1583)
> Caused by: java.io.EOFException
> at
> java.base/java.io.DataInputStream.readUnsignedByte(DataInputStream.java:297)
> at java.base/java.io.DataInputStream.readByte(DataInputStream.java:275)
> at
> org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
> at
> org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:137)
> ... 1 more
> {noformat}
> {noformat}
> org.apache.camel.CamelExecutionException: Exception occurred during execution
> on the exchange: Exchange[31024215DAB9A81-0000000000000001]
> at
> org.apache.camel.CamelExecutionException.wrapCamelExecutionException(CamelExecutionException.java:45)
> at
> org.apache.camel.support.ExchangeHelper.extractResultBody(ExchangeHelper.java:704)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:594)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:590)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.sendBodyAndHeader(DefaultProducerTemplate.java:220)
> at
> org.apache.camel.impl.engine.DefaultProducerTemplate.sendBodyAndHeader(DefaultProducerTemplate.java:212)
> at
> org.apache.camel.component.paho.PahoToDSendDynamicTest.testToDSlashed(PahoToDSendDynamicTest.java:58)
> Caused by: Connection lost (32109) - java.io.EOFException
> at
> org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:197)
> at java.base/java.lang.Thread.run(Thread.java:1583)
> Caused by: java.io.EOFException
> at
> java.base/java.io.DataInputStream.readUnsignedByte(DataInputStream.java:297)
> at java.base/java.io.DataInputStream.readByte(DataInputStream.java:275)
> at
> org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
> at
> org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:137)
> ... 1 more
> {noformat}
> {noformat}
> org.apache.camel.RuntimeCamelException: Connection lost (32109) -
> java.io.EOFException
> at
> org.apache.camel.RuntimeCamelException.wrapRuntimeException(RuntimeCamelException.java:68)
> at
> org.apache.camel.support.service.BaseService.doFail(BaseService.java:431)
> at
> org.apache.camel.support.service.BaseService.fail(BaseService.java:360)
> at
> org.apache.camel.support.service.BaseService.start(BaseService.java:136)
> at
> org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:127)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.startService(AbstractCamelContext.java:3584)
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRouteConsumers(InternalRouteStartupManager.java:425)
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.doStartRouteConsumers(InternalRouteStartupManager.java:341)
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:217)
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.lambda$doStartOrResumeRoutes$1(InternalRouteStartupManager.java:129)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.lambda$startingRoutes$2(AbstractCamelContext.java:1159)
> at
> org.apache.camel.util.concurrent.ContextValueFactory.where(ContextValueFactory.java:65)
> at
> org.apache.camel.util.concurrent.ContextValue.where(ContextValue.java:174)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.startingRoutes(AbstractCamelContext.java:1157)
> at
> org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:117)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:3190)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2796)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2751)
> at
> org.apache.camel.support.service.BaseService.start(BaseService.java:123)
> at
> org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2331)
> at
> org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:214)
> at
> org.apache.camel.test.infra.core.DefaultContextLifeCycleManager.beforeEach(DefaultContextLifeCycleManager.java:80)
> at
> org.apache.camel.test.infra.core.DefaultCamelContextExtension.beforeEach(DefaultCamelContextExtension.java:102)
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
> at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
> Caused by: Connection lost (32109) - java.io.EOFException
> at
> org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:197)
> at java.base/java.lang.Thread.run(Thread.java:1583)
> Caused by: java.io.EOFException
> at
> java.base/java.io.DataInputStream.readUnsignedByte(DataInputStream.java:297)
> at java.base/java.io.DataInputStream.readByte(DataInputStream.java:275)
> at
> org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:92)
> at
> org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:137)
> ... 1 more
> {noformat}
> PahoManualAcksTest.testManualAcks
> PahoOverrideTopicTest.shouldOverride
> PahoToDSendDynamicTest.testToD
> PahoToDSendDynamicTest.testToDSlashed
> PahoToDTest.testToD
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
