See
<https://builds.apache.org/job/kafka-trunk-jdk11/801/display/redirect?page=changes>
Changes:
[wangguoz] MINOR: Clean up partition assignment logic (#7249)
------------------------------------------
[...truncated 3.08 MB...]
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
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
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerOuter[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerOuter[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerLeft[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testInnerLeft[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterInner[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterInner[caching enabled = false] PASSED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterOuter[caching enabled = false] STARTED
org.apache.kafka.streams.integration.TableTableJoinIntegrationTest >
testOuterOuter[caching enabled = false] PASSED
org.apache.kafka.streams.integration.InternalTopicIntegrationTest >
shouldCompactTopicsForKeyValueStoreChangelogs STARTED
org.apache.kafka.streams.integration.InternalTopicIntegrationTest >
shouldCompactTopicsForKeyValueStoreChangelogs PASSED
org.apache.kafka.streams.integration.InternalTopicIntegrationTest >
shouldCompactAndDeleteTopicsForWindowStoreChangelogs STARTED
org.apache.kafka.streams.integration.InternalTopicIntegrationTest >
shouldCompactAndDeleteTopicsForWindowStoreChangelogs PASSED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldFlatTransform STARTED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldFlatTransform PASSED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldFlatTransformValuesWithValueTransformerWithoutKey STARTED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldFlatTransformValuesWithValueTransformerWithoutKey PASSED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldFlatTransformValuesWithKey STARTED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldFlatTransformValuesWithKey PASSED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldTransform STARTED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldTransform PASSED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldTransformValuesWithValueTransformerWithKey STARTED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldTransformValuesWithValueTransformerWithKey PASSED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldTransformValuesWithValueTransformerWithoutKey STARTED
org.apache.kafka.streams.integration.KStreamTransformIntegrationTest >
shouldTransformValuesWithValueTransformerWithoutKey PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryMapValuesState STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryMapValuesState PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldNotMakeStoreAvailableUntilAllStoresAvailable STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldNotMakeStoreAvailableUntilAllStoresAvailable PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
queryOnRebalance STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
queryOnRebalance PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
concurrentAccesses STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
concurrentAccesses PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldAllowToQueryAfterThreadDied STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldAllowToQueryAfterThreadDied PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryStateWithZeroSizedCache STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryStateWithZeroSizedCache PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryMapValuesAfterFilterState STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryMapValuesAfterFilterState PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryFilterState STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryFilterState PASSED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryStateWithNonZeroSizedCache STARTED
org.apache.kafka.streams.integration.QueryableStateIntegrationTest >
shouldBeAbleToQueryStateWithNonZeroSizedCache PASSED
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.PurgeRepartitionTopicIntegrationTest >
shouldRestoreState STARTED
org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest >
shouldRestoreState PASSED
org.apache.kafka.streams.integration.RepartitionOptimizingIntegrationTest >
shouldSendCorrectRecords_OPTIMIZED STARTED
org.apache.kafka.streams.integration.RepartitionOptimizingIntegrationTest >
shouldSendCorrectRecords_OPTIMIZED PASSED
org.apache.kafka.streams.integration.RepartitionOptimizingIntegrationTest >
shouldSendCorrectResults_NO_OPTIMIZATION STARTED
org.apache.kafka.streams.integration.RepartitionOptimizingIntegrationTest >
shouldSendCorrectResults_NO_OPTIMIZATION PASSED
org.apache.kafka.streams.integration.MetricsIntegrationTest >
shouldAddMetricsOnAllLevels STARTED
org.apache.kafka.streams.integration.MetricsIntegrationTest >
shouldAddMetricsOnAllLevels PASSED
org.apache.kafka.streams.integration.MetricsIntegrationTest >
shouldAddMetricsForWindowStore STARTED
org.apache.kafka.streams.integration.MetricsIntegrationTest >
shouldAddMetricsForWindowStore PASSED
org.apache.kafka.streams.integration.MetricsIntegrationTest >
shouldAddMetricsForSessionStore STARTED
org.apache.kafka.streams.integration.MetricsIntegrationTest >
shouldAddMetricsForSessionStore PASSED
org.apache.kafka.streams.integration.MetricsIntegrationTest >
shouldNotAddRocksDBMetricsIfRecordingLevelIsInfo STARTED
org.apache.kafka.streams.integration.MetricsIntegrationTest >
shouldNotAddRocksDBMetricsIfRecordingLevelIsInfo PASSED
org.apache.kafka.streams.integration.ResetIntegrationWithSslTest >
testReprocessingFromScratchAfterResetWithIntermediateUserTopic STARTED
org.apache.kafka.streams.integration.ResetIntegrationWithSslTest >
testReprocessingFromScratchAfterResetWithIntermediateUserTopic PASSED
org.apache.kafka.streams.integration.ResetIntegrationWithSslTest >
testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic STARTED
org.apache.kafka.streams.integration.ResetIntegrationWithSslTest >
testReprocessingFromScratchAfterResetWithoutIntermediateUserTopic PASSED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testInnerRepartitioned[caching enabled = true] STARTED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testInnerRepartitioned[caching enabled = true] PASSED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testOuterRepartitioned[caching enabled = true] STARTED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testOuterRepartitioned[caching enabled = true] PASSED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testInner[caching enabled = true] STARTED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testInner[caching enabled = true] PASSED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testOuter[caching enabled = true] STARTED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testOuter[caching enabled = true] PASSED
org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest >
testLeft[caching enabled = true] STARTED
ERROR: No tool found matching GRADLE_4_10_2_HOME
ERROR: Could not install GRADLE_4_10_3_HOME
java.lang.NullPointerException
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.StreamStreamJoinIntegrationTest >
testLeft[caching enabled = true] SKIPPED
2587 tests completed, 13 failed, 1 skipped
> Task :streams:test FAILED
> Task :streams:test-utils:test
org.apache.kafka.streams.TopologyTestDriverTest > shouldCloseProcessor[Eos
enabled = true] STARTED
org.apache.kafka.streams.TopologyTestDriverTest > shouldCloseProcessor[Eos
enabled = true] PASSED
org.apache.kafka.streams.TopologyTestDriverTest >
shouldFeedStoreFromGlobalKTable[Eos enabled = true] STARTED
The message received from the daemon indicates that the daemon has disappeared.
Build request sent: Build{id=3ce2193e-5ac9-4832-9a07-9b354892bd8b,
currentDir=<https://builds.apache.org/job/kafka-trunk-jdk11/ws/}>
Attempting to read last messages from the daemon log...
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
