See
<https://builds.apache.org/job/kafka-trunk-jdk11/829/display/redirect?page=changes>
Changes:
[github] KAFKA-8086: Use 1 partition for offset topic when possible (#7356)
[bbejeck] KAFKA-6958: Overload methods for group and windowed stream to allow to
------------------------------------------
[...truncated 2.49 MB...]
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testHasNextConditionUsingNullKeys PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testUpperBoundWithZeroTimestamp STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testUpperBoundWithZeroTimestamp PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldSerializeDeserializeExpectedWindowSize STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldSerializeDeserializeExpectedWindowSize PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldSerializeDeserialize STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldSerializeDeserialize PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testLowerBoundMatchesTrailingZeros STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testLowerBoundMatchesTrailingZeros PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testUpperBoundWithKeyBytesLargerThanFirstTimestampByte STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testUpperBoundWithKeyBytesLargerThanFirstTimestampByte PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testSerializeDeserializeOverflowWindowSize STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testSerializeDeserializeOverflowWindowSize PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldExtractWindowFromBinary STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldExtractWindowFromBinary PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testLowerBoundWithMonZeroTimestamp STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testLowerBoundWithMonZeroTimestamp PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testUpperBoundWithKeyBytesLargerAndSmallerThanFirstTimestampByte STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testUpperBoundWithKeyBytesLargerAndSmallerThanFirstTimestampByte PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldExtractKeyFromBinary STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldExtractKeyFromBinary PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldExtractKeyBytesFromBinary STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldExtractKeyBytesFromBinary PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldDeserializeEmptyByteArrayToNull STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldDeserializeEmptyByteArrayToNull PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldSerializeDeserializeExpectedChangelogWindowSize STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldSerializeDeserializeExpectedChangelogWindowSize PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testLowerBoundWithZeroTimestamp STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
testLowerBoundWithZeroTimestamp PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldExtractEndTimeFromBinary STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldExtractEndTimeFromBinary PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldSerializeNullToNull STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldSerializeNullToNull PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldExtractBytesKeyFromBinary STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldExtractBytesKeyFromBinary PASSED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldDeserializeNullToNull STARTED
org.apache.kafka.streams.state.internals.WindowKeySchemaTest >
shouldDeserializeNullToNull PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
emptyIteratorPeekNextKeyShouldThrowNoSuchElementException STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
emptyIteratorPeekNextKeyShouldThrowNoSuchElementException PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
emptyIteratorAlwaysReturnsFalse STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
emptyIteratorAlwaysReturnsFalse PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldThrowNPEIfFromKeyIsNull STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldThrowNPEIfFromKeyIsNull PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldNotGetValuesFromOtherStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldNotGetValuesFromOtherStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldReturnEmptyIteratorIfNoData STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldReturnEmptyIteratorIfNoData PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldThrowNPEIfToKeyIsNull STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldThrowNPEIfToKeyIsNull PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldThrowInvalidStateStoreExceptionIfFetchThrows STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldThrowInvalidStateStoreExceptionIfFetchThrows PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
emptyIteratorNextShouldThrowNoSuchElementException STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
emptyIteratorNextShouldThrowNoSuchElementException PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFetchAllAcrossStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFetchAllAcrossStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFindValueForKeyWhenMultiStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFindValueForKeyWhenMultiStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldThrowNPEIfKeyIsNull STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldThrowNPEIfKeyIsNull PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFetchKeyValueAcrossStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFetchKeyValueAcrossStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldThrowInvalidStateStoreExceptionOnRebalance STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldThrowInvalidStateStoreExceptionOnRebalance PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFetchKeyRangeAcrossStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFetchKeyRangeAcrossStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldGetAllAcrossStores STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldGetAllAcrossStores PASSED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFetchValuesFromWindowStore STARTED
org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStoreTest >
shouldFetchValuesFromWindowStore PASSED
org.apache.kafka.streams.state.internals.StoreChangeLoggerTest >
shouldNotSendRecordHeadersToChangelogTopic STARTED
org.apache.kafka.streams.state.internals.StoreChangeLoggerTest >
shouldNotSendRecordHeadersToChangelogTopic PASSED
org.apache.kafka.streams.state.internals.StoreChangeLoggerTest > testAddRemove
STARTED
org.apache.kafka.streams.state.internals.StoreChangeLoggerTest > testAddRemove
PASSED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldSerializeNew
STARTED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldSerializeNew
PASSED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldSerializeOld
STARTED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldSerializeOld
PASSED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldStoreDifferentValues STARTED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldStoreDifferentValues PASSED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldCompactDuplicates STARTED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldCompactDuplicates PASSED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldAccountForDeduplicationInSizeEstimate STARTED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldAccountForDeduplicationInSizeEstimate PASSED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldDeduplicateNullValues STARTED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldDeduplicateNullValues PASSED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldDeduplicateIndenticalValues STARTED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldDeduplicateIndenticalValues PASSED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldDeduplicateEqualValues STARTED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldDeduplicateEqualValues PASSED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldDeserializeCompactedDuplicates STARTED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldDeserializeCompactedDuplicates PASSED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldDeserializeNew
STARTED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldDeserializeNew
PASSED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldDeserializeOld
STARTED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldDeserializeOld
PASSED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldStoreDifferentValuesWithPriorNull STARTED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldStoreDifferentValuesWithPriorNull PASSED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldSerializeNulls
STARTED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldSerializeNulls
PASSED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldSerializePrior
STARTED
org.apache.kafka.streams.state.internals.BufferValueTest > shouldSerializePrior
PASSED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldStoreDifferentValuesWithOldNull STARTED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldStoreDifferentValuesWithOldNull PASSED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldDeserializePrior STARTED
org.apache.kafka.streams.state.internals.BufferValueTest >
shouldDeserializePrior PASSED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
futureEventsShouldNotCauseSegmentRoll STARTED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
futureEventsShouldNotCauseSegmentRoll PASSED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
shouldCleanupSegmentsThatHaveExpired STARTED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
shouldCleanupSegmentsThatHaveExpired PASSED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
shouldUpdateSegmentFileNameFromOldDateFormatToNewFormat STARTED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
shouldUpdateSegmentFileNameFromOldDateFormatToNewFormat PASSED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
shouldBaseSegmentIntervalOnRetentionAndNumSegments STARTED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
shouldBaseSegmentIntervalOnRetentionAndNumSegments PASSED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
shouldGetSegmentsWithinTimeRangeOutOfOrder STARTED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
shouldGetSegmentsWithinTimeRangeOutOfOrder PASSED
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest >
shouldCloseAllOpenSegments 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.state.internals.KeyValueSegmentsTest >
shouldCloseAllOpenSegments SKIPPED
604 tests completed, 3 failed, 1 skipped
> Task :streams:test FAILED
The message received from the daemon indicates that the daemon has disappeared.
Build request sent: Build{id=b6746b63-ba64-4396-b22a-44b255906f6f,
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 [email protected]
