Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
-
None
Description
The following test has been failing frequently:
:samza-test_2.11:test
testStreamProcessorWithRemove FAILED
java.lang.AssertionError: expected:<120> but was:<140>
at org.junit.Assert.fail(Assert.java:91)
at org.junit.Assert.failNotEquals(Assert.java:645)
at org.junit.Assert.assertEquals(Assert.java:126)
at org.junit.Assert.assertEquals(Assert.java:470)
at org.junit.Assert.assertEquals(Assert.java:454)
at org.apache.samza.processor.TestZkStreamProcessorBase.verifyNumMessages(TestZkStreamProcessorBase.java:252)
at org.apache.samza.processor.TestZkStreamProcessorBase.verifyNumMessages(TestZkStreamProcessorBase.java:215)
at org.apache.samza.test.processor.TestZkStreamProcessor.testStreamProcessorWithRemove(TestZkStreamProcessor.java:246)
156892 [SessionTracker] INFO org.apache.zookeeper.server.SessionTrackerImpl - SessionTrackerImpl exited loop!
156890 [CONTAINER-SHUTDOWN-HOOK] INFO org.apache.samza.container.SamzaContainer - Shutting down, will wait up to 5000 ms
156905 [ThreadJob] INFO org.apache.samza.container.SamzaContainer - Shutting down.
156907 [ThreadJob] INFO org.apache.samza.container.SamzaContainer - Shutting down consumer multiplexer.
156907 [ThreadJob] INFO org.apache.samza.system.kafka.BrokerProxy - Shutting down BrokerProxy for localhost:57193
156908 [ThreadJob] INFO org.apache.samza.system.kafka.BrokerProxy - closing simple consumer...
156911 [SAMZA-BROKER-PROXY-BrokerProxy thread pointed at localhost:57193 for client samza_consumer-RepartitionedSessionizer-1] INFO org.apache.samza.system.kafka.BrokerProxy - Got interrupt exception in broker proxy thread.
156912 [ThreadJob] INFO org.apache.samza.system.kafka.BrokerProxy - Shutting down BrokerProxy for localhost:51410
156912 [ThreadJob] INFO org.apache.samza.system.kafka.BrokerProxy - closing simple consumer...
156913 [SAMZA-BROKER-PROXY-BrokerProxy thread pointed at localhost:51410 for client samza_consumer-RepartitionedSessionizer-1] INFO org.apache.samza.system.kafka.BrokerProxy - Got interrupt exception in broker proxy thread.
156914 [ThreadJob] INFO org.apache.samza.container.SamzaContainer - Shutting down task instance stream tasks.
156921 [ThreadJob] INFO org.apache.samza.container.SamzaContainer - Shutting down task instance stores.
156930 [ThreadJob] INFO org.apache.samza.container.SamzaContainer - Shutting down host statistics monitor.
156930 [ThreadJob] INFO org.apache.samza.container.SamzaContainer - Shutting down producer multiplexer.
156931 [ThreadJob] INFO org.apache.kafka.clients.producer.KafkaProducer - Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
156931 [ThreadJob] INFO org.apache.samza.container.SamzaContainer - Shutting down offset manager.
156932 [ThreadJob] INFO org.apache.samza.container.SamzaContainer - Shutting down metrics reporters.
156932 [ThreadJob] INFO org.apache.samza.container.SamzaContainer - Shutting down JVM metrics.
156933 [ThreadJob] INFO org.apache.samza.container.SamzaContainer - Shutdown complete.
156933 [CONTAINER-SHUTDOWN-HOOK] INFO org.apache.samza.container.SamzaContainer - Shutdown complete
Needs to be looked into. I am disabling the test for now.