[
https://issues.apache.org/jira/browse/KAFKA-6137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222615#comment-16222615
]
Guozhang Wang commented on KAFKA-6137:
--------------------------------------
This seems be caused by this:
{code}
Standard Error
Exception in thread
"restore-test-b1ec6d17-cabc-4e1f-b02e-e116d8f654dc-StreamThread-166"
org.apache.kafka.streams.errors.StreamsException: stream-thread
[restore-test-b1ec6d17-cabc-4e1f-b02e-e116d8f654dc-StreamThread-166] Failed to
rebalance.
at
org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:860)
at
org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:808)
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:774)
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:744)
Caused by: org.apache.kafka.streams.errors.ProcessorStateException: task
directory [/tmp/restore-test6134854033128612495/restore-test/0_0] doesn't exist
and couldn't be created
at
org.apache.kafka.streams.processor.internals.StateDirectory.directoryForTask(StateDirectory.java:93)
at
org.apache.kafka.streams.processor.internals.ProcessorStateManager.<init>(ProcessorStateManager.java:95)
at
org.apache.kafka.streams.processor.internals.AbstractTask.<init>(AbstractTask.java:85)
at
org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:117)
at
org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.createTask(StreamThread.java:404)
at
org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.createTask(StreamThread.java:365)
at
org.apache.kafka.streams.processor.internals.StreamThread$AbstractTaskCreator.createTasks(StreamThread.java:350)
at
org.apache.kafka.streams.processor.internals.TaskManager.addStreamTasks(TaskManager.java:137)
at
org.apache.kafka.streams.processor.internals.TaskManager.createTasks(TaskManager.java:88)
at
org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener.onPartitionsAssigned(StreamThread.java:259)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:264)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:367)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:316)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:295)
at
org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1138)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1103)
at
org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:851)
{code}
> RestoreIntegrationTest sometimes fails with assertion error
> -----------------------------------------------------------
>
> Key: KAFKA-6137
> URL: https://issues.apache.org/jira/browse/KAFKA-6137
> Project: Kafka
> Issue Type: Test
> Components: streams, unit tests
> Reporter: Ted Yu
> Priority: Minor
> Labels: flaky-test
>
> From https://builds.apache.org/job/kafka-1.0-jdk7/62 :
> {code}
> org.apache.kafka.streams.integration.RestoreIntegrationTest >
> shouldSuccessfullyStartWhenLoggingDisabled FAILED
> java.lang.AssertionError
> at org.junit.Assert.fail(Assert.java:86)
> at org.junit.Assert.assertTrue(Assert.java:41)
> at org.junit.Assert.assertTrue(Assert.java:52)
> at
> org.apache.kafka.streams.integration.RestoreIntegrationTest.shouldSuccessfullyStartWhenLoggingDisabled(RestoreIntegrationTest.java:195)
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
