Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Flake in org.apache.beam.sdk.io.mqtt.MqttIOTest.testReadObject: Address already in use #21462

Closed
damccorm opened this issue Jun 4, 2022 · 3 comments
Closed

Flake in org.apache.beam.sdk.io.mqtt.MqttIOTest.testReadObject: Address already in use #21462

damccorm opened this issue Jun 4, 2022 · 3 comments
Assignees
@kennknowles
Labels
bug flake io java mqtt P1
Milestone
2.45.0 Release

Comments

@damccorm
Copy link
Contributor

damccorm commented Jun 4, 2022 


org.apache.beam.sdk.io.mqtt.MqttIOTest.testReadObject

Failing for the past 1 build (Since #4376
)
Took 8 sec.
Error Message
java.io.IOException: Failed to bind to server socket: mqtt://localhost:38845
due to: java.net.BindException: Address already in use (Bind failed)
Stacktrace
java.io.IOException:
Failed to bind to server socket: mqtt://localhost:38845 due to: java.net.BindException: Address already
in use (Bind failed)
	at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:34)
	at
org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:143)
	at org.apache.activemq.transport.tcp.TcpTransportFactory.doBind(TcpTransportFactory.java:62)
	at
org.apache.activemq.transport.TransportFactorySupport.bind(TransportFactorySupport.java:40)
	at org.apache.activemq.broker.BrokerService.createTransportConnector(BrokerService.java:2478)
	at
org.apache.activemq.broker.BrokerService.addConnector(BrokerService.java:338)
	at org.apache.activemq.broker.BrokerService.addConnector(BrokerService.java:328)
	at
org.apache.beam.sdk.io.mqtt.MqttIOTest.startBroker(MqttIOTest.java:77)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at
java.lang.reflect.Method.invoke(Method.java:498)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
	at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
	at
org.junit.internal.runners.statements.RunBefores.invokeMethod(RunBefores.java:33)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
	at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:323)
	at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
	at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
	at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
	at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
	at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
	at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
	at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
	at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
	at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110)
	at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
	at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
	at
org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62)
	at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
	at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
	at
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
	at
com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:119)
	at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at
org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:182)
	at
org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:164)
	at
org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:414)
	at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64)
	at
org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:48)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56)
	at
java.lang.Thread.run(Thread.java:748)
Caused by: java.net.BindException: Address already in use (Bind
failed)
	at java.net.PlainSocketImpl.socketBind(Native Method)
	at java.net.AbstractPlainSocketImpl.bind(AbstractPlainSocketImpl.java:387)
	at
java.net.ServerSocket.bind(ServerSocket.java:390)
	at java.net.ServerSocket.<init>(ServerSocket.java:252)
	at
javax.net.DefaultServerSocketFactory.createServerSocket(ServerSocketFactory.java:231)
	at org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:140)
	...
59 more
Standard Error
Dec 13, 2021 10:17:02 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker
INFO:
Starting ActiveMQ brokerService on 38845
Dec 13, 2021 10:17:02 PM org.apache.activemq.broker.BrokerService
stop
INFO: Apache ActiveMQ 5.14.5 (localhost, null) is shutting down
Dec 13, 2021 10:17:02 PM org.apache.activemq.broker.BrokerService
stop
INFO: Apache ActiveMQ 5.14.5 (localhost, null) is shutdown
Dec 13, 2021 10:17:02 PM org.apache.beam.sdk.io.mqtt.MqttIOTest
startBroker
INFO: Starting ActiveMQ brokerService on 36981
Dec 13, 2021 10:17:03 PM org.apache.activemq.broker.BrokerService
doStartPersistenceAdapter
INFO: Using Persistence Adapter: MemoryPersistenceAdapter
Dec 13, 2021 10:17:03
PM org.apache.activemq.broker.jmx.ManagementContext$1 run
INFO: JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
Dec
13, 2021 10:17:04 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: Apache ActiveMQ 5.14.5
(localhost, ID:apache-ci-beam-jenkins-3-34821-1639433823589-0:1) is starting
Dec 13, 2021 10:17:04
PM org.apache.activemq.transport.TransportServerThreadSupport doStart
INFO: Listening for connections
at: mqtt://localhost:36981
Dec 13, 2021 10:17:04 PM org.apache.activemq.broker.TransportConnector start
INFO:
Connector mqtt://localhost:36981 started
Dec 13, 2021 10:17:04 PM org.apache.activemq.broker.BrokerService
doStartBroker
INFO: Apache ActiveMQ 5.14.5 (localhost, ID:apache-ci-beam-jenkins-3-34821-1639433823589-0:1)
started
Dec 13, 2021 10:17:04 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: For
help or more information please see: http://activemq.apache.org
Dec 13, 2021 10:17:18 PM org.apache.activemq.broker.BrokerService
stop
INFO: Apache ActiveMQ 5.14.5 (localhost, ID:apache-ci-beam-jenkins-3-34821-1639433823589-0:1)
is shutting down
Dec 13, 2021 10:17:18 PM org.apache.activemq.broker.TransportConnector stop
INFO:
Connector mqtt://localhost:36981 stopped
Dec 13, 2021 10:17:18 PM org.apache.activemq.broker.BrokerService
stop
INFO: Apache ActiveMQ 5.14.5 (localhost, ID:apache-ci-beam-jenkins-3-34821-1639433823589-0:1)
uptime 15.281 seconds
Dec 13, 2021 10:17:18 PM org.apache.activemq.broker.BrokerService stop
INFO:
Apache ActiveMQ 5.14.5 (localhost, ID:apache-ci-beam-jenkins-3-34821-1639433823589-0:1) is shutdown
Dec
13, 2021 10:17:18 PM org.apache.beam.sdk.io.mqtt.MqttIOTest startBroker
INFO: Starting ActiveMQ brokerService
on 45689
Dec 13, 2021 10:17:18 PM org.apache.activemq.broker.BrokerService doStartPersistenceAdapter
INFO:
Using Persistence Adapter: MemoryPersistenceAdapter
Dec 13, 2021 10:17:18 PM org.apache.activemq.broker.BrokerService
doStartBroker
INFO: Apache ActiveMQ 5.14.5 (localhost, ID:apache-ci-beam-jenkins-3-34821-1639433823589-0:2)
is starting
Dec 13, 2021 10:17:18 PM org.apache.activemq.broker.jmx.ManagementContext$1 run
INFO:
JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
Dec 13, 2021 10:17:18
PM org.apache.activemq.transport.TransportServerThreadSupport doStart
INFO: Listening for connections
at: mqtt://localhost:45689
Dec 13, 2021 10:17:18 PM org.apache.activemq.broker.TransportConnector start
INFO:
Connector mqtt://localhost:45689 started
Dec 13, 2021 10:17:18 PM org.apache.activemq.broker.BrokerService
doStartBroker
INFO: Apache ActiveMQ 5.14.5 (localhost, ID:apache-ci-beam-jenkins-3-34821-1639433823589-0:2)
started
Dec 13, 2021 10:17:18 PM org.apache.activemq.broker.BrokerService doStartBroker
INFO: For
help or more information please see: http://activemq.apache.org
Dec 13, 2021 10:17:18 PM org.apache.beam.sdk.coders.SerializableCoder
checkEqualsMethodDefined
WARNING: Can't verify serialized elements of type Shard have well defined
equals method. This may produce incorrect results on some PipelineRunner
Dec 13, 2021 10:17:19 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@2c541ea7, maxNumRecords=9223372036854775807,
maxReadTime=PT2S}
Dec 13, 2021 10:17:19 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@52c00c96, maxNumRecords=9223372036854775807,
maxReadTime=PT2S}
Dec 13, 2021 10:17:19 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@2730c42b, maxNumRecords=9223372036854775807,
maxReadTime=PT2S}
Dec 13, 2021 10:17:19 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@52c00c96, maxNumRecords=9223372036854775807,
maxReadTime=PT2S}
Dec 13, 2021 10:17:20 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@7a8ba45e, maxNumRecords=9223372036854775807,
maxReadTime=PT2S}
Dec 13, 2021 10:17:20 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element KV{171548182, Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@7a8ba45e,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}}
Dec 13, 2021 10:17:20 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@7a8ba45e, maxNumRecords=9223372036854775807,
maxReadTime=PT2S}
Dec 13, 2021 10:17:20 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element KV{171548182, Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@7c7843b3,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}}
Dec 13, 2021 10:17:20 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element KV{171548182, TimestampedValue(Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@7c7843b3,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}, -290308-12-21T19:59:05.225Z)}
Dec 13, 2021 10:17:20
PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING:
Coder of type class org.apache.beam.sdk.coders.KvCoder has a #structuralValue method which does not
return true when the encoding of the elements is equal. Element KV{171548182, Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@7c7843b3,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}}
Dec 13, 2021 10:17:21 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element KV{171548182, [TimestampedValue(Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@4f0ed6fe,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}, -290308-12-21T19:59:05.225Z)]}
Dec 13, 2021 10:17:21
PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING:
Coder of type class org.apache.beam.sdk.coders.KvCoder has a #structuralValue method which does not
return true when the encoding of the elements is equal. Element KV{171548182, TimestampedValue(Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@4f0ed6fe,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}, -290308-12-21T19:59:05.225Z)}
Dec 13, 2021 10:17:21
PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING:
Coder of type class org.apache.beam.sdk.coders.KvCoder has a #structuralValue method which does not
return true when the encoding of the elements is equal. Element KV{171548182, [TimestampedValue(Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@4f0ed6fe,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}, -290308-12-21T19:59:05.225Z)]}
Dec 13, 2021 10:17:21
PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING:
Coder of type class org.apache.beam.sdk.coders.KvCoder has a #structuralValue method which does not
return true when the encoding of the elements is equal. Element KV{171548182, TimestampedValue(Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@1d6ae5ef,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}, -290308-12-21T19:59:05.225Z)}
Dec 13, 2021 10:17:21
PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING:
Coder of type class org.apache.beam.sdk.coders.KvCoder has a #structuralValue method which does not
return true when the encoding of the elements is equal. Element KV{171548182, TimestampedValue(Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@1d6ae5ef,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}, -290308-12-21T19:59:05.225Z)}
Dec 13, 2021 10:17:21
PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING:
Coder of type class org.apache.beam.sdk.coders.KvCoder has a #structuralValue method which does not
return true when the encoding of the elements is equal. Element KV{171548182, TimestampedValue(Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@1d6ae5ef,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}, -290308-12-21T19:59:05.225Z)}
Dec 13, 2021 10:17:22
PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING:
Coder of type class org.apache.beam.sdk.coders.KvCoder has a #structuralValue method which does not
return true when the encoding of the elements is equal. Element KV{171548182, TimestampedValue(Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@2cfdbf6a,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}, -290308-12-21T19:59:05.225Z)}
Dec 13, 2021 10:17:22
PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING:
Coder of type class org.apache.beam.sdk.coders.KvCoder has a #structuralValue method which does not
return true when the encoding of the elements is equal. Element KV{171548182, Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@2cfdbf6a,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}}
Dec 13, 2021 10:17:22 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element KV{171548182, TimestampedValue(Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@2cfdbf6a,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}, -290308-12-21T19:59:05.225Z)}
Dec 13, 2021 10:17:22
PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector verifyUnmodifiedThrowingCheckedExceptions
WARNING:
Coder of type class org.apache.beam.sdk.coders.KvCoder has a #structuralValue method which does not
return true when the encoding of the elements is equal. Element KV{171548182, Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@4776c1e9,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}}
Dec 13, 2021 10:17:22 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@4776c1e9, maxNumRecords=9223372036854775807,
maxReadTime=PT2S}
Dec 13, 2021 10:17:22 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element KV{171548182, Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@4776c1e9,
maxNumRecords=9223372036854775807, maxReadTime=PT2S}}
Dec 13, 2021 10:17:24 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@3be221aa, maxNumRecords=9223372036854775807,
maxReadTime=PT2S}
Dec 13, 2021 10:17:24 PM org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.SerializableCoder
has a #structuralValue method which does not return true when the encoding of the elements is equal.
Element Shard{source=org.apache.beam.sdk.io.mqtt.MqttIO$UnboundedMqttSource@3be221aa, maxNumRecords=9223372036854775807,
maxReadTime=PT2S}
Dec 13, 2021 10:17:24 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache
ActiveMQ 5.14.5 (localhost, ID:apache-ci-beam-jenkins-3-34821-1639433823589-0:2) is shutting down
Dec
13, 2021 10:17:24 PM org.apache.activemq.broker.TransportConnector stop
INFO: Connector mqtt://localhost:45689
stopped
Dec 13, 2021 10:17:24 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ
5.14.5 (localhost, ID:apache-ci-beam-jenkins-3-34821-1639433823589-0:2) uptime 6.314 seconds
Dec 13,
2021 10:17:24 PM org.apache.activemq.broker.BrokerService stop
INFO: Apache ActiveMQ 5.14.5 (localhost,
ID:apache-ci-beam-jenkins-3-34821-1639433823589-0:2) is shutdown

Imported from Jira BEAM-13453. Original Jira may contain additional context.
Reported by: tvalentyn.
@johnjcasey
Copy link
Contributor

@tvalentyn has this reoccurred?

@tvalentyn
Copy link
Contributor

I don't know. I haven't recently worked on a Java PR, but there may be a way to query history.

@kennknowles kennknowles self-assigned this Dec 12, 2022
@kennknowles
Copy link
Member

https://ci-beam.apache.org/job/beam_PreCommit_Java_Mqtt_IO_Direct_Cron/ is not flaky

@github-actions github-actions bot added this to the 2.45.0 Release milestone Dec 12, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@kennknowles kennknowles

Labels
bug flake io java mqtt P1
Projects
None yet
Milestone
2.45.0 Release
Development

No branches or pull requests
4 participants
@kennknowles @tvalentyn @damccorm @johnjcasey