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

Reply via email to