[
https://issues.apache.org/jira/browse/KAFKA-6137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16222621#comment-16222621
]
Guozhang Wang commented on KAFKA-6137:
--------------------------------------
It sounds like an environment issue to me as the following condition is not
expected to pass:
{code}
if (!taskDir.exists() && !taskDir.mkdir()) {
throw new ProcessorStateException(
String.format("task directory [%s] doesn't exist and couldn't
be created", taskDir.getPath()));
}
{code}
I'd suggest leaving this ticket open for some time and see if we observe
similar issues again. If not we can close as cannot reproduce.
> 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)
