[
https://issues.apache.org/jira/browse/KAFKA-12185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268805#comment-17268805
]
John Roesler commented on KAFKA-12185:
--------------------------------------
I just saw this fail locally and happened to notice this in the logs:
{code:java}
[2021-01-20 13:03:55,375] ERROR stream-client
[app-StoreQueryIntegrationTestshouldQueryAllStalePartitionStores-ba1cebd9-bccc-4d54-af8a-2f6a51200612]
Encountered the following exception during processing and the registered
exception handler opted to SHUTDOWN_CLIENT. The streams client is going to shut
down now. (org.apache.kafka.streams.KafkaStreams:469)
org.apache.kafka.common.KafkaException: User rebalance callback throws an error
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:436)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:451)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:367)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:508)
at
org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1262)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1231)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211)
at
org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:882)
at
org.apache.kafka.streams.processor.internals.StreamThread.pollPhase(StreamThread.java:839)
at
org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:679)
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:567)
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:547)
Caused by: java.lang.RuntimeException: Unexpected failure to close 1 task(s)
[[0_1]]. First unexpected exception (for task 0_1) follows.
at
org.apache.kafka.streams.processor.internals.TaskManager.handleAssignment(TaskManager.java:311)
at
org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor.onAssignment(StreamsPartitionAssignor.java:1484)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.invokeOnAssignment(ConsumerCoordinator.java:279)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:421)
... 11 more
Caused by: java.util.ConcurrentModificationException
at
java.util.HashMap$EntrySpliterator.forEachRemaining(HashMap.java:1704)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
at
org.apache.kafka.streams.processor.internals.Tasks.convertActiveToStandby(Tasks.java:133)
at
org.apache.kafka.streams.processor.internals.TaskManager.handleCloseAndRecycle(TaskManager.java:394)
at
org.apache.kafka.streams.processor.internals.TaskManager.handleAssignment(TaskManager.java:291)
... 14 more {code}
> Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores
> -----------------------------------------------------------------------
>
> Key: KAFKA-12185
> URL: https://issues.apache.org/jira/browse/KAFKA-12185
> Project: Kafka
> Issue Type: Bug
> Components: streams, unit tests
> Reporter: Matthias J. Sax
> Priority: Critical
> Labels: flaky-test
>
> {{{{java.lang.AssertionError: Application did not reach a RUNNING state for
> all streams instances. Non-running instances:
> \{org.apache.kafka.streams.KafkaStreams@651720d3=NOT_RUNNING}
> at org.junit.Assert.fail(Assert.java:89)
> at
> org.apache.kafka.streams.integration.utils.IntegrationTestUtils.startApplicationAndWaitUntilRunning(IntegrationTestUtils.java:892)
> at
> org.apache.kafka.streams.integration.StoreQueryIntegrationTest.shouldQueryAllStalePartitionStores(StoreQueryIntegrationTest.java:270)}}}}
>
> {{https://github.com/apache/kafka/pull/9835/checks?check_run_id=1666639314}}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
