See <https://builds.apache.org/job/kafka-trunk-jdk9/341/display/redirect?page=changes>
Changes: [wangguoz] MINOR: Optimize KTable-KTable join value getter supplier (#4458) ------------------------------------------ [...truncated 1.74 MB...] 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.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 org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testLeft[caching enabled = true] PASSED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testMultiInner[caching enabled = true] STARTED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testMultiInner[caching enabled = true] PASSED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testLeftRepartitioned[caching enabled = true] STARTED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testLeftRepartitioned[caching enabled = true] PASSED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testInnerRepartitioned[caching enabled = false] STARTED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testInnerRepartitioned[caching enabled = false] PASSED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testOuterRepartitioned[caching enabled = false] STARTED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testOuterRepartitioned[caching enabled = false] PASSED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testInner[caching enabled = false] STARTED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testInner[caching enabled = false] PASSED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testOuter[caching enabled = false] STARTED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testOuter[caching enabled = false] PASSED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testLeft[caching enabled = false] STARTED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testLeft[caching enabled = false] PASSED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testMultiInner[caching enabled = false] STARTED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testMultiInner[caching enabled = false] PASSED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testLeftRepartitioned[caching enabled = false] STARTED org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testLeftRepartitioned[caching enabled = false] PASSED org.apache.kafka.streams.integration.RestoreIntegrationTest > shouldProcessDataFromStoresWithLoggingDisabled STARTED org.apache.kafka.streams.integration.RestoreIntegrationTest > shouldProcessDataFromStoresWithLoggingDisabled PASSED org.apache.kafka.streams.integration.RestoreIntegrationTest > shouldRestoreState STARTED org.apache.kafka.streams.integration.RestoreIntegrationTest > shouldRestoreState PASSED org.apache.kafka.streams.integration.RestoreIntegrationTest > shouldSuccessfullyStartWhenLoggingDisabled STARTED ERROR: No tool found matching GRADLE_3_4_RC_2_HOME ERROR: Could not install GRADLE_4_3_HOME java.lang.NullPointerException org.apache.kafka.streams.integration.RestoreIntegrationTest > shouldSuccessfullyStartWhenLoggingDisabled PASSED org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest > testInner[caching enabled = true] STARTED org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest > testInner[caching enabled = true] PASSED org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest > testLeft[caching enabled = true] STARTED org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest > testLeft[caching enabled = true] PASSED org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest > testInner[caching enabled = false] STARTED org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest > testInner[caching enabled = false] PASSED org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest > testLeft[caching enabled = false] STARTED org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest > testLeft[caching enabled = false] PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest STARTED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldThrowExceptionOverlappingPattern STARTED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldThrowExceptionOverlappingPattern PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldThrowExceptionOverlappingTopic STARTED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldThrowExceptionOverlappingTopic PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldOnlyReadRecordsWhereEarliestSpecifiedWithInvalidCommittedOffsets STARTED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldOnlyReadRecordsWhereEarliestSpecifiedWithInvalidCommittedOffsets PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithDefaultGlobalAutoOffsetResetEarliest STARTED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithDefaultGlobalAutoOffsetResetEarliest PASSED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldThrowStreamsExceptionNoResetSpecified STARTED org.apache.kafka.streams.integration.KStreamsFineGrainedAutoResetIntegrationTest > shouldThrowStreamsExceptionNoResetSpecified 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.PurgeRepartitionTopicIntegrationTest > shouldRestoreState STARTED org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest > shouldRestoreState PASSED org.apache.kafka.streams.integration.GlobalKTableIntegrationTest > shouldKStreamGlobalKTableLeftJoin STARTED org.apache.kafka.streams.integration.GlobalKTableIntegrationTest > shouldKStreamGlobalKTableLeftJoin PASSED org.apache.kafka.streams.integration.GlobalKTableIntegrationTest > shouldRestoreTransactionalMessages STARTED org.apache.kafka.streams.integration.GlobalKTableIntegrationTest > shouldRestoreTransactionalMessages PASSED org.apache.kafka.streams.integration.GlobalKTableIntegrationTest > shouldKStreamGlobalKTableJoin STARTED org.apache.kafka.streams.integration.GlobalKTableIntegrationTest > shouldKStreamGlobalKTableJoin PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRunWithEosEnabled STARTED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRunWithEosEnabled PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToCommitToMultiplePartitions STARTED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToCommitToMultiplePartitions PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldNotViolateEosIfOneTaskFails STARTED org.apache.kafka.streams.integration.EosIntegrationTest > shouldNotViolateEosIfOneTaskFails PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToPerformMultipleTransactions STARTED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToPerformMultipleTransactions PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToCommitMultiplePartitionOffsets STARTED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToCommitMultiplePartitionOffsets PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRunWithTwoSubtopologies STARTED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRunWithTwoSubtopologies PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldNotViolateEosIfOneTaskGetsFencedUsingIsolatedAppInstances STARTED org.apache.kafka.streams.integration.EosIntegrationTest > shouldNotViolateEosIfOneTaskGetsFencedUsingIsolatedAppInstances PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldNotViolateEosIfOneTaskFailsWithState STARTED org.apache.kafka.streams.integration.EosIntegrationTest > shouldNotViolateEosIfOneTaskFailsWithState PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRunWithTwoSubtopologiesAndMultiplePartitions STARTED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRunWithTwoSubtopologiesAndMultiplePartitions PASSED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRestartAfterClose STARTED org.apache.kafka.streams.integration.EosIntegrationTest > shouldBeAbleToRestartAfterClose PASSED org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest > shouldRestoreAndProgressWhenTopicNotWrittenToDuringRestoration STARTED org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest > shouldRestoreAndProgressWhenTopicNotWrittenToDuringRestoration PASSED org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest > shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled STARTED org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest > shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosEnabled PASSED org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest > shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosDisabled STARTED org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest > shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosDisabled PASSED org.apache.kafka.streams.integration.ResetIntegrationTest > shouldNotAllowToResetWhenInputTopicAbsent STARTED ERROR: No tool found matching GRADLE_3_4_RC_2_HOME ERROR: Could not install GRADLE_4_3_HOME java.lang.NullPointerException ERROR: No tool found matching GRADLE_3_4_RC_2_HOME ERROR: Could not install GRADLE_4_3_HOME java.lang.NullPointerException ERROR: No tool found matching GRADLE_3_4_RC_2_HOME ERROR: Could not install GRADLE_4_3_HOME java.lang.NullPointerException ERROR: No tool found matching GRADLE_3_4_RC_2_HOME ERROR: Could not install GRADLE_4_3_HOME java.lang.NullPointerException ERROR: No tool found matching GRADLE_3_4_RC_2_HOME ERROR: Could not install GRADLE_4_3_HOME java.lang.NullPointerException Build timed out (after 360 minutes). Marking the build as failed. Build was aborted Recording test results ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_4_3_HOME=/home/jenkins/tools/gradle/4.3 ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_4_3_HOME=/home/jenkins/tools/gradle/4.3 Not sending mail to unregistered user wangg...@gmail.com