See <https://builds.apache.org/job/kafka-2.4-jdk8/175/display/redirect?page=changes>
Changes: [jason] KAFKA-9749; Transaction coordinator should treat KAFKA_STORAGE_ERROR as ------------------------------------------ [...truncated 7.84 MB...] org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldThrowExceptionThisStoreSupplierWindowSizeDoesNotMatchJoinWindowsWindowSize STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldThrowExceptionThisStoreSupplierWindowSizeDoesNotMatchJoinWindowsWindowSize PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testOuterJoin STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testOuterJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testAsymmetricWindowingAfter STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testAsymmetricWindowingAfter PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testJoin STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testJoin PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldBuildJoinWithCustomStoresAndCorrectWindowSettings STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldBuildJoinWithCustomStoresAndCorrectWindowSettings PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldThrowExceptionOtherStoreSupplierWindowSizeDoesNotMatchJoinWindowsWindowSize STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldThrowExceptionOtherStoreSupplierWindowSizeDoesNotMatchJoinWindowsWindowSize PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldThrowExceptionOtherStoreSupplierRetentionDoNotMatchWindowsSizeAndGrace STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldThrowExceptionOtherStoreSupplierRetentionDoNotMatchWindowsSizeAndGrace PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldThrowExceptionWhenOtherJoinStoreSetsRetainDuplicatesFalse STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldThrowExceptionWhenOtherJoinStoreSetsRetainDuplicatesFalse PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldJoinWithCustomStoreSuppliers STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldJoinWithCustomStoreSuppliers PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testWindowing STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testWindowing PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testAsymmetricWindowingBefore STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > testAsymmetricWindowingBefore PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldThrowExceptionThisStoreSupplierRetentionDoNotMatchWindowsSizeAndGrace STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldThrowExceptionThisStoreSupplierRetentionDoNotMatchWindowsSizeAndGrace PASSED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldExceptionWhenJoinStoresDontHaveUniqueNames STARTED org.apache.kafka.streams.kstream.internals.KStreamKStreamJoinTest > shouldExceptionWhenJoinStoresDontHaveUniqueNames PASSED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > testSendingOldValue STARTED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > testSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > testJoin STARTED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > testJoin PASSED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > testNotSendingOldValue STARTED ERROR: Could not install GRADLE_4_10_3_HOME java.lang.NullPointerException org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > testNotSendingOldValue PASSED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > shouldNotThrowIllegalStateExceptionWhenMultiCacheEvictions STARTED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > shouldNotThrowIllegalStateExceptionWhenMultiCacheEvictions PASSED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > shouldLogAndMeterSkippedRecordsDueToNullLeftKey STARTED org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoinTest > shouldLogAndMeterSkippedRecordsDueToNullLeftKey PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testAggBasic STARTED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testAggBasic PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testCount STARTED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testCount PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testCountWithInternalStore STARTED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testCountWithInternalStore PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testAggRepartition STARTED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testAggRepartition PASSED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testRemoveOldBeforeAddNew STARTED org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testRemoveOldBeforeAddNew PASSED org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest > shouldRoundTripChange STARTED org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest > shouldRoundTripChange PASSED org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest > shouldRoundTripNullChange STARTED org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest > shouldRoundTripNullChange PASSED org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest > shouldRoundTripNewNull STARTED org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest > shouldRoundTripNewNull PASSED org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest > shouldRoundTripOldNull STARTED org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest > shouldRoundTripOldNull PASSED org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest > shouldRoundTripNull STARTED org.apache.kafka.streams.kstream.internals.FullChangeSerdeTest > shouldRoundTripNull PASSED org.apache.kafka.streams.kstream.internals.KStreamFlatMapTest > testFlatMap STARTED org.apache.kafka.streams.kstream.internals.KStreamFlatMapTest > testFlatMap PASSED org.apache.kafka.streams.kstream.internals.TimestampedTupleForwarderTest > shouldForwardRecordsIfWrappedStateStoreDoesNotCache STARTED org.apache.kafka.streams.kstream.internals.TimestampedTupleForwarderTest > shouldForwardRecordsIfWrappedStateStoreDoesNotCache PASSED org.apache.kafka.streams.kstream.internals.TimestampedTupleForwarderTest > shouldNotForwardRecordsIfWrappedStateStoreDoesCache STARTED org.apache.kafka.streams.kstream.internals.TimestampedTupleForwarderTest > shouldNotForwardRecordsIfWrappedStateStoreDoesCache PASSED org.apache.kafka.streams.kstream.internals.TimestampedTupleForwarderTest > shouldSetFlushListenerOnWrappedStateStore STARTED org.apache.kafka.streams.kstream.internals.TimestampedTupleForwarderTest > shouldSetFlushListenerOnWrappedStateStore PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldRemoveMergedSessionsFromStateStore STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldRemoveMergedSessionsFromStateStore PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldMergeSessions STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldMergeSessions PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldLogAndMeterWhenSkippingNullKey STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldLogAndMeterWhenSkippingNullKey PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldHandleMultipleSessionsAndMerging STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldHandleMultipleSessionsAndMerging PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldImmediatelyForwardNewSessionWhenNonCachedStore STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldImmediatelyForwardNewSessionWhenNonCachedStore PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldGetAggregatedValuesFromValueGetter STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldGetAggregatedValuesFromValueGetter PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldImmediatelyForwardRemovedSessionsWhenMerging STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldImmediatelyForwardRemovedSessionsWhenMerging PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldUpdateSessionIfTheSameTime STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldUpdateSessionIfTheSameTime PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldHaveMultipleSessionsForSameIdWhenTimestampApartBySessionGap STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldHaveMultipleSessionsForSameIdWhenTimestampApartBySessionGap PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldCreateSingleSessionWhenWithinGap STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldCreateSingleSessionWhenWithinGap PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldLogAndMeterWhenSkippingLateRecordWithZeroGrace STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldLogAndMeterWhenSkippingLateRecordWithZeroGrace PASSED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldLogAndMeterWhenSkippingLateRecordWithNonzeroGrace STARTED org.apache.kafka.streams.kstream.internals.KStreamSessionWindowAggregateProcessorTest > shouldLogAndMeterWhenSkippingLateRecordWithNonzeroGrace PASSED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldInitialiseFlatTransformProcessor STARTED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldInitialiseFlatTransformProcessor PASSED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldTransformInputRecordToMultipleOutputRecords STARTED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldTransformInputRecordToMultipleOutputRecords PASSED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldGetFlatTransformProcessor STARTED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldGetFlatTransformProcessor PASSED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldCloseFlatTransformProcessor STARTED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldCloseFlatTransformProcessor PASSED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldAllowNullAsResultOfTransform STARTED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldAllowNullAsResultOfTransform PASSED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldAllowEmptyListAsResultOfTransform STARTED org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest > shouldAllowEmptyListAsResultOfTransform PASSED org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest > testJoin STARTED Build timed out (after 660 minutes). Marking the build as failed. Build was aborted [FINDBUGS] Collecting findbugs analysis files... Setting GRADLE_4_10_3_HOME=/home/jenkins/tools/gradle/4.10.3 [FINDBUGS] Searching for all files in <https://builds.apache.org/job/kafka-2.4-jdk8/ws/> that match the pattern **/build/reports/findbugs/*.xml [FINDBUGS] No files found. Configuration error? Setting GRADLE_4_10_3_HOME=/home/jenkins/tools/gradle/4.10.3 No credentials specified Setting GRADLE_4_10_3_HOME=/home/jenkins/tools/gradle/4.10.3 <Git Blamer> Using GitBlamer to create author and commit information for all warnings. <Git Blamer> GIT_COMMIT=e463bce0401bd8d73ce1f3f012052e679c285abd, workspace=<https://builds.apache.org/job/kafka-2.4-jdk8/ws/> [FINDBUGS] Computing warning deltas based on reference build #174 Recording test results Setting GRADLE_4_10_3_HOME=/home/jenkins/tools/gradle/4.10.3 org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest.testJoin failed, log available in <https://builds.apache.org/job/kafka-2.4-jdk8/ws/streams/build/reports/testOutput/org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest.testJoin.test.stdout> org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest > testJoin FAILED java.util.NoSuchElementException: Empty topic: output at org.apache.kafka.streams.TopologyTestDriver.readRecord(TopologyTestDriver.java:789) at org.apache.kafka.streams.TestOutputTopic.readRecord(TestOutputTopic.java:100) at org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest.assertOutputKeyValueTimestamp(KTableKTableInnerJoinTest.java:475) at org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest.doTestJoin(KTableKTableInnerJoinTest.java:434) at org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest.testJoin(KTableKTableInnerJoinTest.java:82) org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest > testNotSendingOldValues STARTED org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest.testNotSendingOldValues failed, log available in <https://builds.apache.org/job/kafka-2.4-jdk8/ws/streams/build/reports/testOutput/org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest.testNotSendingOldValues.test.stdout> org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest > testNotSendingOldValues FAILED java.lang.IllegalStateException: Shutdown in progress at java.lang.ApplicationShutdownHooks.add(ApplicationShutdownHooks.java:66) at java.lang.Runtime.addShutdownHook(Runtime.java:211) at org.apache.kafka.test.TestUtils.tempDirectory(TestUtils.java:265) at org.apache.kafka.test.TestUtils.tempDirectory(TestUtils.java:235) at org.apache.kafka.test.TestUtils.tempDirectory(TestUtils.java:245) at org.apache.kafka.test.StreamsTestUtils.getStreamsConfig(StreamsTestUtils.java:57) at org.apache.kafka.test.StreamsTestUtils.getStreamsConfig(StreamsTestUtils.java:65) at org.apache.kafka.streams.kstream.internals.KTableKTableInnerJoinTest.<init>(KTableKTableInnerJoinTest.java:66) 1776 tests completed, 2 failed > Task :streams:test FAILED > Task :tools:test org.apache.kafka.trogdor.coordinator.CoordinatorTest > testTaskRequest STARTED Setting GRADLE_4_10_3_HOME=/home/jenkins/tools/gradle/4.10.3