[
https://issues.apache.org/jira/browse/KAFKA-8078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818779#comment-16818779
]
Matthias J. Sax commented on KAFKA-8078:
----------------------------------------
This time `testInnerOuter` (caching disabled) failed:
[https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk11/detail/kafka-trunk-jdk11/437/tests]
{quote}java.lang.AssertionError: Condition not met within timeout 30000. Did
not receive all 2 records from topic outputTopic
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:361)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:338)
at
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinValuesRecordsReceived(IntegrationTestUtils.java:634)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.checkResult(AbstractJoinIntegrationTest.java:168)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:210)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerOuter(TableTableJoinIntegrationTest.java:299){quote}
STDERR:
{quote}Exception in thread
"table-table-join-integration-test-inner-outer-7e77baff-8165-424f-bbae-196cc4584d76-StreamThread-81"
org.apache.kafka.streams.errors.StreamsException: stream-thread
[table-table-join-integration-test-inner-outer-7e77baff-8165-424f-bbae-196cc4584d76-StreamThread-81]
Failed to rebalance.
at
org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:949)
at
org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:849)
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:804)
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:773)
Caused by: org.apache.kafka.streams.errors.ProcessorStateException: task
directory
[/tmp/kafka-18411042429127811683/junit15346870036826305327/table-table-join-integration-test-inner-outer/0_0]
doesn't exist and couldn't be created
at
org.apache.kafka.streams.processor.internals.StateDirectory.directoryForTask(StateDirectory.java:103)
at
org.apache.kafka.streams.processor.internals.ProcessorStateManager.<init>(ProcessorStateManager.java:72)
at
org.apache.kafka.streams.processor.internals.AbstractTask.<init>(AbstractTask.java:92)
at
org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:188)
at
org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:172)
at
org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.createTask(StreamThread.java:447)
at
org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.createTask(StreamThread.java:398)
at
org.apache.kafka.streams.processor.internals.StreamThread$AbstractTaskCreator.createTasks(StreamThread.java:383)
at
org.apache.kafka.streams.processor.internals.TaskManager.addStreamTasks(TaskManager.java:148)
at
org.apache.kafka.streams.processor.internals.TaskManager.createTasks(TaskManager.java:107)
at
org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener.onPartitionsAssigned(StreamThread.java:280)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:275)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:411)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:345)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:343)
at
org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1229)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1194)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1179)
at
org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:940)
... 3 more{quote}
> Flaky Test TableTableJoinIntegrationTest#testInnerInner
> -------------------------------------------------------
>
> Key: KAFKA-8078
> URL: https://issues.apache.org/jira/browse/KAFKA-8078
> Project: Kafka
> Issue Type: Bug
> Components: streams, unit tests
> Affects Versions: 2.3.0
> Reporter: Matthias J. Sax
> Priority: Critical
> Labels: flaky-test
> Fix For: 2.3.0
>
>
> [https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk8/detail/kafka-trunk-jdk8/3445/tests]
> {quote}java.lang.AssertionError: Condition not met within timeout 15000.
> Never received expected final result.
> at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:365)
> at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:325)
> at
> org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:246)
> at
> org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerInner(TableTableJoinIntegrationTest.java:196){quote}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
