See
<https://builds.apache.org/job/kafka-trunk-jdk11/774/display/redirect?page=changes>
Changes:
[gwen] KAFKA-8391; Temporarily ignore flaky Connect rebalance integration tests
[rhauch] MINOR: Fix the doc of scheduled.rebalance.max.delay.ms config property
------------------------------------------
[...truncated 2.26 MB...]
java.lang.AssertionError:
Expected: <KeyValue(start, 1566823721666)>
but: was null
at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:18)
at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:6)
at
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest.shouldReduceSessionWindows(KStreamAggregationIntegrationTest.java:667)
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduce STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduce PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregate STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregate PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCount STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCount PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldGroupByKey STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldGroupByKey PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCountWithInternalStore STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCountWithInternalStore PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCountUnlimitedWindows STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCountUnlimitedWindows PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduceWindowed STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldReduceWindowed PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCountSessionWindows STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldCountSessionWindows PASSED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregateWindowed STARTED
org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest >
shouldAggregateWindowed PASSED
org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest >
shouldWorkWithRebalance STARTED
org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest.shouldWorkWithRebalance
failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest.shouldWorkWithRebalance.test.stdout>
org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest >
shouldWorkWithRebalance FAILED
java.lang.AssertionError: verifying tagg
fail: key=694 tagg=[ConsumerRecord(topic = tagg, partition = 0, leaderEpoch
= 0, offset = 5, CreateTime = 1566824033327, serialized key size = 3,
serialized value size = 8, headers = RecordHeaders(headers = [], isReadOnly =
false), key = 694, value = 2)] expected=null
outputEvents: [ConsumerRecord(topic = tagg, partition = 0, leaderEpoch
= 0, offset = 5, CreateTime = 1566824033327, serialized key size = 3,
serialized value size = 8, headers = RecordHeaders(headers = [], isReadOnly =
false), key = 694, value = 2)]
verifying suppressed min-suppressed
verifying min-suppressed with 10 keys
verifying suppressed sws-suppressed
verifying min with 10 keys
verifying max with 10 keys
verifying dif with 10 keys
verifying sum with 10 keys
verifying cnt with 10 keys
verifying avg with 10 keys
at org.junit.Assert.fail(Assert.java:89)
at org.junit.Assert.assertTrue(Assert.java:42)
at
org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest.shouldWorkWithRebalance(SmokeTestDriverIntegrationTest.java:137)
org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest >
shouldReduce STARTED
org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest >
shouldReduce PASSED
org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest >
shouldGroupByKey STARTED
org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest >
shouldGroupByKey PASSED
org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest >
shouldReduceWindowed STARTED
org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest >
shouldReduceWindowed PASSED
org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest >
shouldRecoverBufferAfterShutdown[0: eosEnabled=false] STARTED
org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest >
shouldRecoverBufferAfterShutdown[0: eosEnabled=false] PASSED
org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest >
shouldRecoverBufferAfterShutdown[1: eosEnabled=true] STARTED
org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest >
shouldRecoverBufferAfterShutdown[1: eosEnabled=true] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftInner[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftInner[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:338)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftOuter[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftOuter[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftOuter[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftOuter[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftOuter(TableTableJoinIntegrationTest.java:432)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftLeft[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftLeft[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftLeft[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftLeft[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftLeft(TableTableJoinIntegrationTest.java:383)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterLeft[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuterLeft[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuterLeft[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterLeft[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuterLeft(TableTableJoinIntegrationTest.java:529)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInner[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInner[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInner[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInner[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInner(TableTableJoinIntegrationTest.java:100)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuter[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuter[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuter[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuter[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuter(TableTableJoinIntegrationTest.java:162)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeft[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeft[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeft[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeft[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeft(TableTableJoinIntegrationTest.java:131)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerInner[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerInner[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerInner[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerInner[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerInner(TableTableJoinIntegrationTest.java:197)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerOuter[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerOuter[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerOuter[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerOuter[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerOuter(TableTableJoinIntegrationTest.java:289)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerLeft[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerLeft[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerLeft[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerLeft[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testInnerLeft(TableTableJoinIntegrationTest.java:244)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterInner[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuterInner[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuterInner[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterInner[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuterInner(TableTableJoinIntegrationTest.java:482)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterOuter[caching enabled = true] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuterOuter[caching
enabled = true] failed, log available in
<https://builds.apache.org/job/kafka-trunk-jdk11/ws/streams/build/reports/testOutput/org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuterOuter[caching>
enabled = true].test.stdout
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterOuter[caching enabled = true] FAILED
java.lang.AssertionError: Condition not met within timeout 15000. Never
received expected final result.
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:336)
at
org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:255)
at
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testOuterOuter(TableTableJoinIntegrationTest.java:580)
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftInner[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftOuter[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftOuter[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftLeft[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeftLeft[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterLeft[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterLeft[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInner[caching enabled = false] STARTED
ERROR: No tool found matching GRADLE_4_10_2_HOME
ERROR: Could not install GRADLE_4_10_3_HOME
java.lang.NullPointerException
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuter[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuter[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeft[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testLeft[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerInner[caching enabled = false] STARTED
Build timed out (after 480 minutes). Marking the build as failed.
Build was aborted
Recording test results
ERROR: No tool found matching GRADLE_4_10_2_HOME
Setting GRADLE_4_10_3_HOME=/home/jenkins/tools/gradle/4.10.3
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerInner[caching enabled = false] SKIPPED
111 tests completed, 18 failed, 1 skipped
ERROR: No tool found matching GRADLE_4_10_2_HOME
Setting GRADLE_4_10_3_HOME=/home/jenkins/tools/gradle/4.10.3
Not sending mail to unregistered user nore...@github.com
Not sending mail to unregistered user wangg...@gmail.com
Not sending mail to unregistered user g...@confluent.io
