[ https://issues.apache.org/jira/browse/KAFKA-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15897882#comment-15897882 ]
Armin Braun commented on KAFKA-3874: ------------------------------------ I think this one is still pretty flaky. I see this (https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/2032/) kind of failure a lot locally and on Jenkins. Should we reopen this one maybe? Or add a new JIRA since the way it fails appears to have changed to: {code} Error Message java.lang.AssertionError: Condition not met within timeout 30000. Expecting 3 records from topic output-topic-2 while only received 0: [] Stacktrace java.lang.AssertionError: Condition not met within timeout 30000. Expecting 3 records from topic output-topic-2 while only received 0: [] at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:257) at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:206) at org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:175) at org.apache.kafka.streams.integration.KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion(KStreamKTableJoinIntegrationTest.java:297) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50) at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47) at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) {code} > Transient test failure: > org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion > ----------------------------------------------------------------------------------------------------------- > > Key: KAFKA-3874 > URL: https://issues.apache.org/jira/browse/KAFKA-3874 > Project: Kafka > Issue Type: Sub-task > Components: streams, unit tests > Reporter: Ismael Juma > Assignee: Damian Guy > Labels: transient-unit-test-failure > Fix For: 0.10.1.0 > > > The failure I am recording happened in Jenkins, but I had a similar failure > locally (and two other integration tests failed in that run). > {code} > Expected: <[KeyValue(europe, 13), KeyValue(americas, 4), KeyValue(asia, 25), > KeyValue(americas, 23), KeyValue(europe, 69), KeyValue(americas, 101), > KeyValue(europe, 109), KeyValue(asia, 124)]> > but: was <[KeyValue(europe, 122), KeyValue(americas, 105), > KeyValue(asia, 149), KeyValue(americas, 124), KeyValue(europe, 178), > KeyValue(americas, 202), KeyValue(europe, 218), KeyValue(asia, 248)]> > at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) > at org.junit.Assert.assertThat(Assert.java:956) > at org.junit.Assert.assertThat(Assert.java:923) > at > org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion(JoinIntegrationTest.java:258) > {code} > https://builds.apache.org/job/kafka-trunk-git-pr-jdk7/4254/ -- This message was sent by Atlassian JIRA (v6.3.15#6346)