You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/07/18 09:34:49 UTC
Build failed in Jenkins: kafka-trunk-jdk10 #288
See <https://builds.apache.org/job/kafka-trunk-jdk10/288/display/redirect?page=changes>
Changes:
[jason] MINOR: Fix broken Javadoc on [AbstractIndex|OffsetIndex] (#5370)
[github] MINOR: web docs fixes on message header (#5381)
[harsha] MINOR: Updated Quickstart to mention log.dirs (#5361)
------------------------------------------
[...truncated 1.99 MB...]
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullJoinerOnOuterJoin STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullJoinerOnOuterJoin PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldCreateSourceAndSinkNodesForRepartitioningTopic STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldCreateSourceAndSinkNodesForRepartitioningTopic PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullJoinerJoin STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullJoinerJoin PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldAllowNullStoreInJoin STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldAllowNullStoreInJoin PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldThrowNullPointerOnTransformValuesWithKeyWhenTransformerSupplierIsNull STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldThrowNullPointerOnTransformValuesWithKeyWhenTransformerSupplierIsNull PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > testStateStoreLazyEval STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > testStateStoreLazyEval PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldThrowNullPointerOnLeftJoinWhenMaterializedIsNull STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldThrowNullPointerOnLeftJoinWhenMaterializedIsNull PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldThrowNullPointerOnFilterWhenMaterializedIsNull STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldThrowNullPointerOnFilterWhenMaterializedIsNull PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > testKTable STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > testKTable PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullPredicateOnFilterNot STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldNotAllowNullPredicateOnFilterNot PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldThrowNullPointerOnTransformValuesWithKeyWhenMaterializedIsNull STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > shouldThrowNullPointerOnTransformValuesWithKeyWhenMaterializedIsNull PASSED
org.apache.kafka.streams.kstream.internals.KTableImplTest > testValueGetter STARTED
org.apache.kafka.streams.kstream.internals.KTableImplTest > testValueGetter 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
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.AbstractStreamTest > testShouldBeExtensible STARTED
org.apache.kafka.streams.kstream.internals.AbstractStreamTest > testShouldBeExtensible PASSED
org.apache.kafka.streams.kstream.internals.AbstractStreamTest > testToInternalValueTransformerSupplierSuppliesNewTransformers STARTED
org.apache.kafka.streams.kstream.internals.AbstractStreamTest > testToInternalValueTransformerSupplierSuppliesNewTransformers PASSED
org.apache.kafka.streams.kstream.internals.AbstractStreamTest > testToInternlValueTransformerSupplierSuppliesNewTransformers STARTED
org.apache.kafka.streams.kstream.internals.AbstractStreamTest > testToInternlValueTransformerSupplierSuppliesNewTransformers PASSED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > shouldJoinRegardlessIfMatchFoundOnStreamUpdates STARTED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > shouldJoinRegardlessIfMatchFoundOnStreamUpdates PASSED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > shouldRequireCopartitionedStreams STARTED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > shouldRequireCopartitionedStreams PASSED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > shouldClearTableEntryOnNullValueUpdates STARTED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > shouldClearTableEntryOnNullValueUpdates PASSED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > shouldNotJoinOnTableUpdates STARTED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > shouldNotJoinOnTableUpdates PASSED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > shouldJoinWithEmptyTableOnStreamUpdates STARTED
org.apache.kafka.streams.kstream.internals.KStreamKTableLeftJoinTest > shouldJoinWithEmptyTableOnStreamUpdates PASSED
org.apache.kafka.streams.kstream.internals.KStreamPeekTest > shouldNotAllowNullAction STARTED
org.apache.kafka.streams.kstream.internals.KStreamPeekTest > shouldNotAllowNullAction PASSED
org.apache.kafka.streams.kstream.internals.KStreamPeekTest > shouldObserveStreamElements STARTED
org.apache.kafka.streams.kstream.internals.KStreamPeekTest > shouldObserveStreamElements 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 > shouldForwardToCorrectProcessorNodeWhenMultiCacheEvictions STARTED
org.apache.kafka.streams.kstream.internals.KTableAggregateTest > shouldForwardToCorrectProcessorNodeWhenMultiCacheEvictions 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 > testAggCoalesced STARTED
org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testAggCoalesced 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.KTableAggregateTest > testCountCoalesced STARTED
org.apache.kafka.streams.kstream.internals.KTableAggregateTest > testCountCoalesced PASSED
org.apache.kafka.streams.kstream.TimeWindowedDeserializerTest > testWindowedValueDeserializerNoArgConstructors STARTED
org.apache.kafka.streams.kstream.TimeWindowedDeserializerTest > testWindowedValueDeserializerNoArgConstructors PASSED
org.apache.kafka.streams.kstream.TimeWindowedDeserializerTest > testWindowedKeyDeserializerNoArgConstructors STARTED
org.apache.kafka.streams.kstream.TimeWindowedDeserializerTest > testWindowedKeyDeserializerNoArgConstructors PASSED
org.apache.kafka.streams.kstream.SessionWindowsTest > retentionTimeShouldBeGapIfGapIsLargerThanDefaultRetentionTime STARTED
org.apache.kafka.streams.kstream.SessionWindowsTest > retentionTimeShouldBeGapIfGapIsLargerThanDefaultRetentionTime PASSED
org.apache.kafka.streams.kstream.SessionWindowsTest > shouldSetWindowGap STARTED
org.apache.kafka.streams.kstream.SessionWindowsTest > shouldSetWindowGap PASSED
org.apache.kafka.streams.kstream.SessionWindowsTest > shouldBeEqualWhenGapAndMaintainMsAreTheSame STARTED
org.apache.kafka.streams.kstream.SessionWindowsTest > shouldBeEqualWhenGapAndMaintainMsAreTheSame PASSED
org.apache.kafka.streams.kstream.SessionWindowsTest > retentionTimeMustNotBeNegative STARTED
org.apache.kafka.streams.kstream.SessionWindowsTest > retentionTimeMustNotBeNegative PASSED
org.apache.kafka.streams.kstream.SessionWindowsTest > shouldNotBeEqualWhenMaintainMsDifferent STARTED
org.apache.kafka.streams.kstream.SessionWindowsTest > shouldNotBeEqualWhenMaintainMsDifferent PASSED
org.apache.kafka.streams.kstream.SessionWindowsTest > windowSizeMustNotBeZero STARTED
org.apache.kafka.streams.kstream.SessionWindowsTest > windowSizeMustNotBeZero PASSED
org.apache.kafka.streams.kstream.SessionWindowsTest > windowSizeMustNotBeNegative STARTED
org.apache.kafka.streams.kstream.SessionWindowsTest > windowSizeMustNotBeNegative PASSED
org.apache.kafka.streams.kstream.SessionWindowsTest > shouldSetWindowRetentionTime STARTED
org.apache.kafka.streams.kstream.SessionWindowsTest > shouldSetWindowRetentionTime PASSED
org.apache.kafka.streams.kstream.SessionWindowsTest > shouldNotBeEqualWhenGapIsDifferent STARTED
org.apache.kafka.streams.kstream.SessionWindowsTest > shouldNotBeEqualWhenGapIsDifferent PASSED
org.apache.kafka.streams.kstream.WindowTest > shouldThrowIfEndIsSmallerThanStart STARTED
org.apache.kafka.streams.kstream.WindowTest > shouldThrowIfEndIsSmallerThanStart PASSED
org.apache.kafka.streams.kstream.WindowTest > shouldNotBeEqualIfDifferentWindowType STARTED
org.apache.kafka.streams.kstream.WindowTest > shouldNotBeEqualIfDifferentWindowType PASSED
org.apache.kafka.streams.kstream.WindowTest > shouldBeEqualIfStartAndEndSame STARTED
org.apache.kafka.streams.kstream.WindowTest > shouldBeEqualIfStartAndEndSame PASSED
org.apache.kafka.streams.kstream.WindowTest > shouldNotBeEqualIfNull STARTED
org.apache.kafka.streams.kstream.WindowTest > shouldNotBeEqualIfNull PASSED
org.apache.kafka.streams.kstream.WindowTest > shouldThrowIfStartIsNegative STARTED
org.apache.kafka.streams.kstream.WindowTest > shouldThrowIfStartIsNegative PASSED
org.apache.kafka.streams.kstream.WindowTest > shouldNotBeEqualIfStartOrEndIsDifferent STARTED
org.apache.kafka.streams.kstream.WindowTest > shouldNotBeEqualIfStartOrEndIsDifferent PASSED
org.apache.kafka.streams.kstream.WindowsTest > retentionTimeMustNotBeNegative STARTED
org.apache.kafka.streams.kstream.WindowsTest > retentionTimeMustNotBeNegative PASSED
org.apache.kafka.streams.kstream.WindowsTest > numberOfSegmentsMustBeAtLeastTwo STARTED
org.apache.kafka.streams.kstream.WindowsTest > numberOfSegmentsMustBeAtLeastTwo PASSED
org.apache.kafka.streams.kstream.WindowsTest > shouldSetWindowRetentionTime STARTED
org.apache.kafka.streams.kstream.WindowsTest > shouldSetWindowRetentionTime PASSED
org.apache.kafka.streams.kstream.WindowsTest > shouldSetNumberOfSegments STARTED
org.apache.kafka.streams.kstream.WindowsTest > shouldSetNumberOfSegments PASSED
1905 tests completed, 2 failed
> Task :streams:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/kafka-trunk-jdk10/ws/streams/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2h 14m 28s
67 actionable tasks: 45 executed, 22 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Not sending mail to unregistered user github@alasdairhodge.co.uk
Jenkins build is back to normal : kafka-trunk-jdk10 #295
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-trunk-jdk10/295/display/redirect?page=changes>
Build failed in Jenkins: kafka-trunk-jdk10 #294
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-trunk-jdk10/294/display/redirect?page=changes>
Changes:
[rajinisivaram] KAFKA-7182: SASL/OAUTHBEARER client response missing %x01 seps (#5391)
------------------------------------------
[...truncated 1.98 MB...]
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToNewClientWithoutFlippingAssignmentBetweenExistingClients PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignAtLeastOneTaskToEachClientIfPossible STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignAtLeastOneTaskToEachClientIfPossible PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHosts STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHosts PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldRebalanceTasksToClientsBasedOnCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldRebalanceTasksToClientsBasedOnCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousStandbyTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousStandbyTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotAssignStandbyTaskReplicasWhenNoClientAvailableWithoutHavingTheTaskAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotAssignStandbyTaskReplicasWhenNoClientAvailableWithoutHavingTheTaskAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignEachActiveTaskToOneClientWhenMoreClientsThanTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignEachActiveTaskToOneClientWhenMoreClientsThanTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithStandByTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithStandByTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToNewClient STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToNewClient PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignOneActiveTaskToEachProcessWhenTaskCountSameAsProcessCount STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignOneActiveTaskToEachProcessWhenTaskCountSameAsProcessCount PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossClientsWhenCapacityLessThanTaskCount STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossClientsWhenCapacityLessThanTaskCount PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldBalanceActiveAndStandbyTasksAcrossAvailableClients STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldBalanceActiveAndStandbyTasksAcrossAvailableClients PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignActiveAndStandbyTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignActiveAndStandbyTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousActiveTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousActiveTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToClientWithPreviousStandbyTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToClientWithPreviousStandbyTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossAllClientsWhenCapacityAndTaskCountTheSame STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossAllClientsWhenCapacityAndTaskCountTheSame PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignMoreTasksToClientWithMoreCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignMoreTasksToClientWithMoreCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMigrateActiveTasksToNewProcessWithoutChangingAllAssignments STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMigrateActiveTasksToNewProcessWithoutChangingAllAssignments PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldKeepActiveTaskStickynessWhenMoreClientThanActiveTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldKeepActiveTaskStickynessWhenMoreClientThanActiveTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithNoStandByTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithNoStandByTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotMoveAnyTasksWhenNewTasksAdded STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotMoveAnyTasksWhenNewTasksAdded PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToMultipleNewClients STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToMultipleNewClients PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMoveMinimalNumberOfTasksWhenPreviouslyAboveCapacityAndNewClientAdded STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMoveMinimalNumberOfTasksWhenPreviouslyAboveCapacityAndNewClientAdded PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion3 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion3 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldUseLatestSupportedVersionByDefault STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldUseLatestSupportedVersionByDefault PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveUnfulfilledQuotaWhenActiveTaskSizeLessThanCapacityTimesTasksPerThread STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveUnfulfilledQuotaWhenActiveTaskSizeLessThanCapacityTimesTasksPerThread PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfActiveTaskAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfActiveTaskAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldUseMultiplesOfCapacityToDetermineClientWithMoreAvailableCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldUseMultiplesOfCapacityToDetermineClientWithMoreAvailableCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveNotReachedCapacityWhenAssignedTasksLessThanCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveNotReachedCapacityWhenAssignedTasksLessThanCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousActiveTasksToPreviousAssignedAndPreviousActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousActiveTasksToPreviousAssignedAndPreviousActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfThisClientStateIsZero STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfThisClientStateIsZero PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveAssignedTaskIfTaskNotAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveAssignedTaskIfTaskNotAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityTheSameButFewerAssignedTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityTheSameButFewerAssignedTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddStandbyTasksToBothStandbyAndActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddStandbyTasksToBothStandbyAndActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousStandbyTasksToPreviousAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousStandbyTasksToPreviousAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfOtherClientStateIsZero STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfOtherClientStateIsZero PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityIsTheSameButAssignedTasksIsLess STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityIsTheSameButAssignedTasksIsLess PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddActiveTasksToBothAssignedAndActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddActiveTasksToBothAssignedAndActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfStandbyTaskAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfStandbyTaskAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveUnfulfilledQuotaWhenActiveTaskSizeGreaterEqualThanCapacityTimesTasksPerThread STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveUnfulfilledQuotaWhenActiveTaskSizeGreaterEqualThanCapacityTimesTasksPerThread PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityHigherAndSameAssignedTaskCount STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityHigherAndSameAssignedTaskCount PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveReachedCapacityWhenAssignedTasksGreaterThanOrEqualToCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveReachedCapacityWhenAssignedTasksGreaterThanOrEqualToCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion3 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion3 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldAllowToDecodeFutureSupportedVersion STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldAllowToDecodeFutureSupportedVersion PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldUseLatestSupportedVersionByDefault STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldUseLatestSupportedVersionByDefault PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > shouldThrowStreamsException STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > shouldThrowStreamsException PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp PASSED
1898 tests completed, 4 failed
> Task :streams:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/kafka-trunk-jdk10/ws/streams/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2h 24m 16s
67 actionable tasks: 53 executed, 14 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Not sending mail to unregistered user lindong28@gmail.com
Not sending mail to unregistered user rajinisivaram@googlemail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Build failed in Jenkins: kafka-trunk-jdk10 #293
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-trunk-jdk10/293/display/redirect?page=changes>
Changes:
[github] KAFKA-3514: Remove min timestamp tracker (#5382)
------------------------------------------
[...truncated 1.97 MB...]
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToNewClientWithoutFlippingAssignmentBetweenExistingClients PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignAtLeastOneTaskToEachClientIfPossible STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignAtLeastOneTaskToEachClientIfPossible PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHosts STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHosts PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldRebalanceTasksToClientsBasedOnCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldRebalanceTasksToClientsBasedOnCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousStandbyTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousStandbyTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotAssignStandbyTaskReplicasWhenNoClientAvailableWithoutHavingTheTaskAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotAssignStandbyTaskReplicasWhenNoClientAvailableWithoutHavingTheTaskAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignEachActiveTaskToOneClientWhenMoreClientsThanTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignEachActiveTaskToOneClientWhenMoreClientsThanTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithStandByTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithStandByTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToNewClient STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToNewClient PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignOneActiveTaskToEachProcessWhenTaskCountSameAsProcessCount STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignOneActiveTaskToEachProcessWhenTaskCountSameAsProcessCount PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossClientsWhenCapacityLessThanTaskCount STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossClientsWhenCapacityLessThanTaskCount PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldBalanceActiveAndStandbyTasksAcrossAvailableClients STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldBalanceActiveAndStandbyTasksAcrossAvailableClients PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignActiveAndStandbyTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignActiveAndStandbyTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousActiveTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousActiveTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToClientWithPreviousStandbyTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToClientWithPreviousStandbyTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossAllClientsWhenCapacityAndTaskCountTheSame STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossAllClientsWhenCapacityAndTaskCountTheSame PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignMoreTasksToClientWithMoreCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignMoreTasksToClientWithMoreCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMigrateActiveTasksToNewProcessWithoutChangingAllAssignments STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMigrateActiveTasksToNewProcessWithoutChangingAllAssignments PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldKeepActiveTaskStickynessWhenMoreClientThanActiveTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldKeepActiveTaskStickynessWhenMoreClientThanActiveTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithNoStandByTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithNoStandByTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotMoveAnyTasksWhenNewTasksAdded STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotMoveAnyTasksWhenNewTasksAdded PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToMultipleNewClients STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToMultipleNewClients PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMoveMinimalNumberOfTasksWhenPreviouslyAboveCapacityAndNewClientAdded STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMoveMinimalNumberOfTasksWhenPreviouslyAboveCapacityAndNewClientAdded PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion3 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion3 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldUseLatestSupportedVersionByDefault STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldUseLatestSupportedVersionByDefault PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveUnfulfilledQuotaWhenActiveTaskSizeLessThanCapacityTimesTasksPerThread STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveUnfulfilledQuotaWhenActiveTaskSizeLessThanCapacityTimesTasksPerThread PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfActiveTaskAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfActiveTaskAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldUseMultiplesOfCapacityToDetermineClientWithMoreAvailableCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldUseMultiplesOfCapacityToDetermineClientWithMoreAvailableCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveNotReachedCapacityWhenAssignedTasksLessThanCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveNotReachedCapacityWhenAssignedTasksLessThanCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousActiveTasksToPreviousAssignedAndPreviousActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousActiveTasksToPreviousAssignedAndPreviousActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfThisClientStateIsZero STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfThisClientStateIsZero PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveAssignedTaskIfTaskNotAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveAssignedTaskIfTaskNotAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityTheSameButFewerAssignedTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityTheSameButFewerAssignedTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddStandbyTasksToBothStandbyAndActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddStandbyTasksToBothStandbyAndActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousStandbyTasksToPreviousAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousStandbyTasksToPreviousAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfOtherClientStateIsZero STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfOtherClientStateIsZero PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityIsTheSameButAssignedTasksIsLess STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityIsTheSameButAssignedTasksIsLess PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddActiveTasksToBothAssignedAndActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddActiveTasksToBothAssignedAndActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfStandbyTaskAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfStandbyTaskAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveUnfulfilledQuotaWhenActiveTaskSizeGreaterEqualThanCapacityTimesTasksPerThread STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveUnfulfilledQuotaWhenActiveTaskSizeGreaterEqualThanCapacityTimesTasksPerThread PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityHigherAndSameAssignedTaskCount STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityHigherAndSameAssignedTaskCount PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveReachedCapacityWhenAssignedTasksGreaterThanOrEqualToCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveReachedCapacityWhenAssignedTasksGreaterThanOrEqualToCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion3 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion3 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldAllowToDecodeFutureSupportedVersion STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldAllowToDecodeFutureSupportedVersion PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldUseLatestSupportedVersionByDefault STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldUseLatestSupportedVersionByDefault PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > shouldThrowStreamsException STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > shouldThrowStreamsException PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp PASSED
1898 tests completed, 2 failed
> Task :streams:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/kafka-trunk-jdk10/ws/streams/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2h 20m 38s
67 actionable tasks: 53 executed, 14 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Not sending mail to unregistered user lindong28@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Build failed in Jenkins: kafka-trunk-jdk10 #292
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-trunk-jdk10/292/display/redirect?page=changes>
Changes:
[github] MINOR: Update build.gradle and release.py to upload streams-scala_2.12
------------------------------------------
[...truncated 1.98 MB...]
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToNewClient PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignOneActiveTaskToEachProcessWhenTaskCountSameAsProcessCount STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignOneActiveTaskToEachProcessWhenTaskCountSameAsProcessCount PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossClientsWhenCapacityLessThanTaskCount STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossClientsWhenCapacityLessThanTaskCount PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldBalanceActiveAndStandbyTasksAcrossAvailableClients STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldBalanceActiveAndStandbyTasksAcrossAvailableClients PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignActiveAndStandbyTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignActiveAndStandbyTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousActiveTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousActiveTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToClientWithPreviousStandbyTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToClientWithPreviousStandbyTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossAllClientsWhenCapacityAndTaskCountTheSame STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossAllClientsWhenCapacityAndTaskCountTheSame PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignMoreTasksToClientWithMoreCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignMoreTasksToClientWithMoreCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMigrateActiveTasksToNewProcessWithoutChangingAllAssignments STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMigrateActiveTasksToNewProcessWithoutChangingAllAssignments PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldKeepActiveTaskStickynessWhenMoreClientThanActiveTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldKeepActiveTaskStickynessWhenMoreClientThanActiveTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithNoStandByTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithNoStandByTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotMoveAnyTasksWhenNewTasksAdded STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotMoveAnyTasksWhenNewTasksAdded PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToMultipleNewClients STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToMultipleNewClients PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMoveMinimalNumberOfTasksWhenPreviouslyAboveCapacityAndNewClientAdded STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMoveMinimalNumberOfTasksWhenPreviouslyAboveCapacityAndNewClientAdded PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion3 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion3 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldUseLatestSupportedVersionByDefault STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldUseLatestSupportedVersionByDefault PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveUnfulfilledQuotaWhenActiveTaskSizeLessThanCapacityTimesTasksPerThread STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveUnfulfilledQuotaWhenActiveTaskSizeLessThanCapacityTimesTasksPerThread PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfActiveTaskAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfActiveTaskAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldUseMultiplesOfCapacityToDetermineClientWithMoreAvailableCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldUseMultiplesOfCapacityToDetermineClientWithMoreAvailableCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveNotReachedCapacityWhenAssignedTasksLessThanCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveNotReachedCapacityWhenAssignedTasksLessThanCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousActiveTasksToPreviousAssignedAndPreviousActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousActiveTasksToPreviousAssignedAndPreviousActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfThisClientStateIsZero STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfThisClientStateIsZero PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveAssignedTaskIfTaskNotAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveAssignedTaskIfTaskNotAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityTheSameButFewerAssignedTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityTheSameButFewerAssignedTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddStandbyTasksToBothStandbyAndActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddStandbyTasksToBothStandbyAndActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousStandbyTasksToPreviousAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousStandbyTasksToPreviousAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfOtherClientStateIsZero STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfOtherClientStateIsZero PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityIsTheSameButAssignedTasksIsLess STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityIsTheSameButAssignedTasksIsLess PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddActiveTasksToBothAssignedAndActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddActiveTasksToBothAssignedAndActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfStandbyTaskAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfStandbyTaskAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveUnfulfilledQuotaWhenActiveTaskSizeGreaterEqualThanCapacityTimesTasksPerThread STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveUnfulfilledQuotaWhenActiveTaskSizeGreaterEqualThanCapacityTimesTasksPerThread PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityHigherAndSameAssignedTaskCount STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityHigherAndSameAssignedTaskCount PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveReachedCapacityWhenAssignedTasksGreaterThanOrEqualToCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveReachedCapacityWhenAssignedTasksGreaterThanOrEqualToCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion3 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion3 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldAllowToDecodeFutureSupportedVersion STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldAllowToDecodeFutureSupportedVersion PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldUseLatestSupportedVersionByDefault STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldUseLatestSupportedVersionByDefault PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnNotKnownTimestampWhenNoRecordsEverAdded STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnNotKnownTimestampWhenNoRecordsEverAdded PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldThrowNullPointerExceptionWhenTryingToAddNullElement STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldThrowNullPointerExceptionWhenTryingToAddNullElement PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLowestAvailableTimestampFromAllInputs STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLowestAvailableTimestampFromAllInputs PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnTimestampOfOnlyRecord STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnTimestampOfOnlyRecord PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLowestAvailableTimestampAfterPreviousLowestRemoved STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLowestAvailableTimestampAfterPreviousLowestRemoved PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldIgnoreNullRecordOnRemove STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldIgnoreNullRecordOnRemove PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLastKnownTimestampWhenAllElementsHaveBeenRemoved STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLastKnownTimestampWhenAllElementsHaveBeenRemoved PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > shouldThrowStreamsException STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > shouldThrowStreamsException PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp PASSED
pure virtual method called
terminate called without an active exception
1900 tests completed, 2 failed
> Task :streams:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':streams:test'.
> Process 'Gradle Test Executor 5' finished with non-zero exit value 134
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.8.1/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2h 25m 14s
67 actionable tasks: 53 executed, 14 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Not sending mail to unregistered user lindong28@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Build failed in Jenkins: kafka-trunk-jdk10 #291
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-trunk-jdk10/291/display/redirect?page=changes>
Changes:
[jason] KAFKA-4994; Remove findbugs suppression for OffsetStorageWriter (#5385)
------------------------------------------
[...truncated 1.98 MB...]
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithStandByTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToNewClient STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToNewClient PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignOneActiveTaskToEachProcessWhenTaskCountSameAsProcessCount STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignOneActiveTaskToEachProcessWhenTaskCountSameAsProcessCount PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossClientsWhenCapacityLessThanTaskCount STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossClientsWhenCapacityLessThanTaskCount PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldBalanceActiveAndStandbyTasksAcrossAvailableClients STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldBalanceActiveAndStandbyTasksAcrossAvailableClients PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignActiveAndStandbyTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignActiveAndStandbyTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousActiveTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotHaveSameAssignmentOnAnyTwoHostsWhenThereArePreviousActiveTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToClientWithPreviousStandbyTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksToClientWithPreviousStandbyTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossAllClientsWhenCapacityAndTaskCountTheSame STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldReBalanceTasksAcrossAllClientsWhenCapacityAndTaskCountTheSame PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignMoreTasksToClientWithMoreCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignMoreTasksToClientWithMoreCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMigrateActiveTasksToNewProcessWithoutChangingAllAssignments STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMigrateActiveTasksToNewProcessWithoutChangingAllAssignments PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldKeepActiveTaskStickynessWhenMoreClientThanActiveTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldKeepActiveTaskStickynessWhenMoreClientThanActiveTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithNoStandByTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTopicGroupIdEvenlyAcrossClientsWithNoStandByTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotMoveAnyTasksWhenNewTasksAdded STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldNotMoveAnyTasksWhenNewTasksAdded PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToMultipleNewClients STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldAssignTasksNotPreviouslyActiveToMultipleNewClients PASSED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMoveMinimalNumberOfTasksWhenPreviouslyAboveCapacityAndNewClientAdded STARTED
org.apache.kafka.streams.processor.internals.assignment.StickyTaskAssignorTest > shouldMoveMinimalNumberOfTasksWhenPreviouslyAboveCapacityAndNewClientAdded PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion3 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldEncodeAndDecodeVersion3 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldThrowForUnknownVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldUseLatestSupportedVersionByDefault STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldUseLatestSupportedVersionByDefault PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveUnfulfilledQuotaWhenActiveTaskSizeLessThanCapacityTimesTasksPerThread STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveUnfulfilledQuotaWhenActiveTaskSizeLessThanCapacityTimesTasksPerThread PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfActiveTaskAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfActiveTaskAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldUseMultiplesOfCapacityToDetermineClientWithMoreAvailableCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldUseMultiplesOfCapacityToDetermineClientWithMoreAvailableCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveNotReachedCapacityWhenAssignedTasksLessThanCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveNotReachedCapacityWhenAssignedTasksLessThanCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousActiveTasksToPreviousAssignedAndPreviousActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousActiveTasksToPreviousAssignedAndPreviousActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfThisClientStateIsZero STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfThisClientStateIsZero PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveAssignedTaskIfTaskNotAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveAssignedTaskIfTaskNotAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityTheSameButFewerAssignedTasks STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityTheSameButFewerAssignedTasks PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddStandbyTasksToBothStandbyAndActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddStandbyTasksToBothStandbyAndActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousStandbyTasksToPreviousAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddPreviousStandbyTasksToPreviousAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfOtherClientStateIsZero STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldThrowIllegalStateExceptionIfCapacityOfOtherClientStateIsZero PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityIsTheSameButAssignedTasksIsLess STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityIsTheSameButAssignedTasksIsLess PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddActiveTasksToBothAssignedAndActive STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldAddActiveTasksToBothAssignedAndActive PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfStandbyTaskAssigned STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveAssignedTaskIfStandbyTaskAssigned PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveUnfulfilledQuotaWhenActiveTaskSizeGreaterEqualThanCapacityTimesTasksPerThread STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldNotHaveUnfulfilledQuotaWhenActiveTaskSizeGreaterEqualThanCapacityTimesTasksPerThread PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityHigherAndSameAssignedTaskCount STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveMoreAvailableCapacityWhenCapacityHigherAndSameAssignedTaskCount PASSED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveReachedCapacityWhenAssignedTasksGreaterThanOrEqualToCapacity STARTED
org.apache.kafka.streams.processor.internals.assignment.ClientStateTest > shouldHaveReachedCapacityWhenAssignedTasksGreaterThanOrEqualToCapacity PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion3 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeAndDecodeVersion3 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldAllowToDecodeFutureSupportedVersion STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldAllowToDecodeFutureSupportedVersion PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion1 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion1 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion2 STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldThrowForUnknownVersion2 PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldUseLatestSupportedVersionByDefault STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldUseLatestSupportedVersionByDefault PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnNotKnownTimestampWhenNoRecordsEverAdded STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnNotKnownTimestampWhenNoRecordsEverAdded PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldThrowNullPointerExceptionWhenTryingToAddNullElement STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldThrowNullPointerExceptionWhenTryingToAddNullElement PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLowestAvailableTimestampFromAllInputs STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLowestAvailableTimestampFromAllInputs PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnTimestampOfOnlyRecord STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnTimestampOfOnlyRecord PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLowestAvailableTimestampAfterPreviousLowestRemoved STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLowestAvailableTimestampAfterPreviousLowestRemoved PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldIgnoreNullRecordOnRemove STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldIgnoreNullRecordOnRemove PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLastKnownTimestampWhenAllElementsHaveBeenRemoved STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest > shouldReturnLastKnownTimestampWhenAllElementsHaveBeenRemoved PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > usePreviousTimeOnInvalidTimestamp PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > shouldThrowStreamsException STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > shouldThrowStreamsException PASSED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp STARTED
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestampTest > extractMetadataTimestamp PASSED
1900 tests completed, 2 failed
> Task :streams:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/kafka-trunk-jdk10/ws/streams/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2h 19m 47s
67 actionable tasks: 66 executed, 1 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Not sending mail to unregistered user lindong28@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Build failed in Jenkins: kafka-trunk-jdk10 #290
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-trunk-jdk10/290/display/redirect?page=changes>
Changes:
[lindong28] MINOR: Consolidate Topic create calls in Test classes
------------------------------------------
[...truncated 1.98 MB...]
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowToAddGlobalStoreWithSourceNameEqualsProcessorName PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddSourceWithOffsetReset STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddSourceWithOffsetReset PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStoreWithSource STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStoreWithSource PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddInternalTopicConfigForRepartitionTopics STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddInternalTopicConfigForRepartitionTopics PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullProcessorNameWhenConnectingProcessorAndStateStores STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullProcessorNameWhenConnectingProcessorAndStateStores PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSourceWithSameName STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSourceWithSameName PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddMoreThanOnePatternSourceNode STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddMoreThanOnePatternSourceNode PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddTimestampExtractorWithPatternPerSource STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddTimestampExtractorWithPatternPerSource PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddProcessorWithSameName STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddProcessorWithSameName PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldSetCorrectSourceNodesWithRegexUpdatedTopics STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldSetCorrectSourceNodesWithRegexUpdatedTopics PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldConnectRegexMatchedTopicsToStateStore STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldConnectRegexMatchedTopicsToStateStore PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSourceWithSameTopic STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSourceWithSameTopic PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testTopicGroupsByStateStore STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testTopicGroupsByStateStore PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddSourceWithoutOffsetReset STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddSourceWithoutOffsetReset PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStoreWithDuplicates STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStoreWithDuplicates PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullStateStoreNameWhenConnectingProcessorAndStateStores STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullStateStoreNameWhenConnectingProcessorAndStateStores PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddTimestampExtractorPerSource STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddTimestampExtractorPerSource PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testPatternSourceTopic STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testPatternSourceTopic PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAssociateStateStoreNameWhenStateStoreSupplierIsExternal STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAssociateStateStoreNameWhenStateStoreSupplierIsExternal PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddProcessorWithEmptyParents STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddProcessorWithEmptyParents PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkWithWrongParent STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkWithWrongParent PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testPatternMatchesAlreadyProvidedTopicSource STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testPatternMatchesAlreadyProvidedTopicSource PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkConnectedWithMultipleParent STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkConnectedWithMultipleParent PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testSubscribeTopicNameAndPattern STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testSubscribeTopicNameAndPattern PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullTopicChooserWhenAddingSink STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullTopicChooserWhenAddingSink PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddPatternSourceWithoutOffsetReset STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddPatternSourceWithoutOffsetReset PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAddNullInternalTopic STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAddNullInternalTopic PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddProcessorWithWrongParent STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddProcessorWithWrongParent PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullNameWhenAddingProcessor STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldNotAllowNullNameWhenAddingProcessor PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddSourcePatternWithOffsetReset STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldAddSourcePatternWithOffsetReset PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStore STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStore PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkConnectedWithParent STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddSinkConnectedWithParent PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStoreWithNonExistingProcessor STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > testAddStateStoreWithNonExistingProcessor PASSED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldCorrectlyMapStateStoreToInternalTopics STARTED
org.apache.kafka.streams.processor.internals.InternalTopologyBuilderTest > shouldCorrectlyMapStateStoreToInternalTopics PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnRegisterWhenContextIsInitialized STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnRegisterWhenContextIsInitialized PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnTimestampFromRecordContext STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnTimestampFromRecordContext PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnOffsetFromRecordContext STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnOffsetFromRecordContext PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnPartitionFromRecordContext STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnPartitionFromRecordContext PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnTopicFromRecordContext STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnTopicFromRecordContext PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowNullPointerOnRegisterIfStateStoreIsNull STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowNullPointerOnRegisterIfStateStoreIsNull PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldNotThrowIllegalStateExceptionOnRegisterWhenContextIsNotInitialized STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldNotThrowIllegalStateExceptionOnRegisterWhenContextIsNotInitialized PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnTimestampIfNoRecordContext STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnTimestampIfNoRecordContext PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnPartitionIfNoRecordContext STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnPartitionIfNoRecordContext PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnNullIfHeadersAreNotSet STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnNullIfHeadersAreNotSet PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnHeadersFromRecordContext STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnHeadersFromRecordContext PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnTopicIfNoRecordContext STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnTopicIfNoRecordContext PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnOffsetIfNoRecordContext STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnOffsetIfNoRecordContext PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnHeadersIfNoRecordContext STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldThrowIllegalStateExceptionOnHeadersIfNoRecordContext PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnNullIfTopicEqualsNonExistTopic STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > shouldReturnNullIfTopicEqualsNonExistTopic PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > appConfigsShouldReturnUnrecognizedValues STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > appConfigsShouldReturnUnrecognizedValues PASSED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > appConfigsShouldReturnParsedValues STARTED
org.apache.kafka.streams.processor.internals.AbstractProcessorContextTest > appConfigsShouldReturnParsedValues PASSED
org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest > logAndSkipOnInvalidTimestamp STARTED
org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest > logAndSkipOnInvalidTimestamp PASSED
org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest > extractMetadataTimestamp STARTED
org.apache.kafka.streams.processor.LogAndSkipOnInvalidTimestampTest > extractMetadataTimestamp PASSED
org.apache.kafka.streams.processor.FailOnInvalidTimestampTest > failOnInvalidTimestamp STARTED
org.apache.kafka.streams.processor.FailOnInvalidTimestampTest > failOnInvalidTimestamp PASSED
org.apache.kafka.streams.processor.FailOnInvalidTimestampTest > extractMetadataTimestamp STARTED
org.apache.kafka.streams.processor.FailOnInvalidTimestampTest > extractMetadataTimestamp PASSED
org.apache.kafka.streams.processor.WallclockTimestampExtractorTest > extractSystemTimestamp STARTED
org.apache.kafka.streams.processor.WallclockTimestampExtractorTest > extractSystemTimestamp PASSED
1905 tests completed, 1 failed
> Task :streams:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/kafka-trunk-jdk10/ws/streams/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
See https://docs.gradle.org/4.8.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2h 18m 59s
67 actionable tasks: 46 executed, 21 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Not sending mail to unregistered user lindong28@gmail.com
Not sending mail to unregistered user github@alasdairhodge.co.uk
Build failed in Jenkins: kafka-trunk-jdk10 #289
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/kafka-trunk-jdk10/289/display/redirect?page=changes>
Changes:
[github] KAFKA-7168: Treat connection close during SSL handshake as retriable
[github] MINOR: remove unused MeteredKeyValueStore (#5380)
[github] MINOR: Remove references to version 1.2 in docs (#5386)
[matthias] MINOR: improve docs version numbers (#5372)
------------------------------------------
[...truncated 1.56 MB...]
kafka.controller.PartitionStateMachineTest > testInvalidNonexistentPartitionToOnlinePartitionTransition PASSED
kafka.controller.PartitionStateMachineTest > testInvalidNonexistentPartitionToOfflinePartitionTransition STARTED
kafka.controller.PartitionStateMachineTest > testInvalidNonexistentPartitionToOfflinePartitionTransition PASSED
kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOnlineTransition STARTED
kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOnlineTransition PASSED
kafka.controller.PartitionStateMachineTest > testNewPartitionToOnlinePartitionTransitionZkUtilsExceptionFromCreateStates STARTED
kafka.controller.PartitionStateMachineTest > testNewPartitionToOnlinePartitionTransitionZkUtilsExceptionFromCreateStates PASSED
kafka.controller.PartitionStateMachineTest > testInvalidNewPartitionToNonexistentPartitionTransition STARTED
kafka.controller.PartitionStateMachineTest > testInvalidNewPartitionToNonexistentPartitionTransition PASSED
kafka.controller.PartitionStateMachineTest > testNewPartitionToOnlinePartitionTransition STARTED
kafka.controller.PartitionStateMachineTest > testNewPartitionToOnlinePartitionTransition PASSED
kafka.controller.PartitionStateMachineTest > testInvalidOnlinePartitionToNewPartitionTransition STARTED
kafka.controller.PartitionStateMachineTest > testInvalidOnlinePartitionToNewPartitionTransition PASSED
kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransitionErrorCodeFromStateLookup STARTED
kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransitionErrorCodeFromStateLookup PASSED
kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOnlineTransitionForControlledShutdown STARTED
kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOnlineTransitionForControlledShutdown PASSED
kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransitionZkUtilsExceptionFromStateLookup STARTED
kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransitionZkUtilsExceptionFromStateLookup PASSED
kafka.controller.PartitionStateMachineTest > testInvalidOnlinePartitionToNonexistentPartitionTransition STARTED
kafka.controller.PartitionStateMachineTest > testInvalidOnlinePartitionToNonexistentPartitionTransition PASSED
kafka.controller.PartitionStateMachineTest > testInvalidOfflinePartitionToNewPartitionTransition STARTED
kafka.controller.PartitionStateMachineTest > testInvalidOfflinePartitionToNewPartitionTransition PASSED
kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransition STARTED
kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransition PASSED
kafka.controller.ControllerEventManagerTest > testEventThatThrowsException STARTED
kafka.controller.ControllerEventManagerTest > testEventThatThrowsException PASSED
kafka.controller.ControllerEventManagerTest > testSuccessfulEvent STARTED
kafka.controller.ControllerEventManagerTest > testSuccessfulEvent PASSED
kafka.controller.ControllerFailoverTest > classMethod STARTED
kafka.controller.ControllerFailoverTest > classMethod FAILED
java.lang.AssertionError: Found unexpected threads during @BeforeClass, allThreads=Set(Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, scala-execution-context-global-222, kafka-request-handler-2, ThrottledChannelReaper-Request, Test worker, Test worker-SendThread(some.invalid.hostname.foo.bar.local:65535), scala-execution-context-global-225, /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 2, /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 3, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Thread-1303-EventThread, Signal Dispatcher, main, ExpirationReaper-0-DeleteRecords, ThrottledChannelReaper-Produce, Test worker-SendThread(localhost:41342), Test worker-SendThread(some.invalid.hostname.foo.bar.local:2181), Test worker-SendThread(localhost:50992), Thread-1303-SendThread(localhost:51283), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Common-Cleaner, Finalizer, ThrottledChannelReaper-Fetch, kafka-admin-client-thread | adminclient-135), unexpected=Set(kafka-admin-client-thread | adminclient-135)
kafka.controller.ControllerFailoverTest > classMethod STARTED
kafka.controller.ControllerFailoverTest > classMethod FAILED
java.lang.AssertionError: Found unexpected threads during @AfterClass, allThreads=Set(Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, scala-execution-context-global-222, kafka-request-handler-2, ThrottledChannelReaper-Request, Test worker, Test worker-SendThread(some.invalid.hostname.foo.bar.local:65535), scala-execution-context-global-225, /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 2, /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 3, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Thread-1303-EventThread, Signal Dispatcher, main, ExpirationReaper-0-DeleteRecords, ThrottledChannelReaper-Produce, Test worker-SendThread(localhost:41342), Test worker-SendThread(some.invalid.hostname.foo.bar.local:2181), Test worker-SendThread(localhost:50992), Thread-1303-SendThread(localhost:51283), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Common-Cleaner, Finalizer, ThrottledChannelReaper-Fetch, kafka-admin-client-thread | adminclient-135), unexpected=Set(kafka-admin-client-thread | adminclient-135)
kafka.network.SocketServerTest > testGracefulClose STARTED
kafka.network.SocketServerTest > testGracefulClose PASSED
kafka.network.SocketServerTest > testSendActionResponseWithThrottledChannelWhereThrottlingAlreadyDone STARTED
kafka.network.SocketServerTest > testSendActionResponseWithThrottledChannelWhereThrottlingAlreadyDone PASSED
kafka.network.SocketServerTest > controlThrowable STARTED
kafka.network.SocketServerTest > controlThrowable PASSED
kafka.network.SocketServerTest > testRequestMetricsAfterStop STARTED
kafka.network.SocketServerTest > testRequestMetricsAfterStop PASSED
kafka.network.SocketServerTest > testConnectionIdReuse STARTED
kafka.network.SocketServerTest > testConnectionIdReuse PASSED
kafka.network.SocketServerTest > testClientDisconnectionUpdatesRequestMetrics STARTED
kafka.network.SocketServerTest > testClientDisconnectionUpdatesRequestMetrics PASSED
kafka.network.SocketServerTest > testProcessorMetricsTags STARTED
kafka.network.SocketServerTest > testProcessorMetricsTags PASSED
kafka.network.SocketServerTest > testMaxConnectionsPerIp STARTED
kafka.network.SocketServerTest > testMaxConnectionsPerIp PASSED
kafka.network.SocketServerTest > testConnectionId STARTED
kafka.network.SocketServerTest > testConnectionId PASSED
kafka.network.SocketServerTest > testBrokerSendAfterChannelClosedUpdatesRequestMetrics STARTED
kafka.network.SocketServerTest > testBrokerSendAfterChannelClosedUpdatesRequestMetrics PASSED
kafka.network.SocketServerTest > testNoOpAction STARTED
kafka.network.SocketServerTest > testNoOpAction PASSED
kafka.network.SocketServerTest > simpleRequest STARTED
kafka.network.SocketServerTest > simpleRequest PASSED
kafka.network.SocketServerTest > closingChannelException STARTED
kafka.network.SocketServerTest > closingChannelException PASSED
kafka.network.SocketServerTest > testSendActionResponseWithThrottledChannelWhereThrottlingInProgress STARTED
kafka.network.SocketServerTest > testSendActionResponseWithThrottledChannelWhereThrottlingInProgress PASSED
kafka.network.SocketServerTest > testIdleConnection STARTED
kafka.network.SocketServerTest > testIdleConnection PASSED
kafka.network.SocketServerTest > testClientDisconnectionWithStagedReceivesFullyProcessed STARTED
kafka.network.SocketServerTest > testClientDisconnectionWithStagedReceivesFullyProcessed PASSED
kafka.network.SocketServerTest > testZeroMaxConnectionsPerIp STARTED
kafka.network.SocketServerTest > testZeroMaxConnectionsPerIp PASSED
kafka.network.SocketServerTest > testMetricCollectionAfterShutdown STARTED
kafka.network.SocketServerTest > testMetricCollectionAfterShutdown PASSED
kafka.network.SocketServerTest > testSessionPrincipal STARTED
kafka.network.SocketServerTest > testSessionPrincipal PASSED
kafka.network.SocketServerTest > configureNewConnectionException STARTED
kafka.network.SocketServerTest > configureNewConnectionException PASSED
kafka.network.SocketServerTest > testMaxConnectionsPerIpOverrides STARTED
kafka.network.SocketServerTest > testMaxConnectionsPerIpOverrides PASSED
kafka.network.SocketServerTest > processNewResponseException STARTED
kafka.network.SocketServerTest > processNewResponseException PASSED
kafka.network.SocketServerTest > processCompletedSendException STARTED
kafka.network.SocketServerTest > processCompletedSendException PASSED
kafka.network.SocketServerTest > processDisconnectedException STARTED
kafka.network.SocketServerTest > processDisconnectedException PASSED
kafka.network.SocketServerTest > sendCancelledKeyException STARTED
kafka.network.SocketServerTest > sendCancelledKeyException PASSED
kafka.network.SocketServerTest > processCompletedReceiveException STARTED
kafka.network.SocketServerTest > processCompletedReceiveException PASSED
kafka.network.SocketServerTest > testSocketsCloseOnShutdown STARTED
kafka.network.SocketServerTest > testSocketsCloseOnShutdown PASSED
kafka.network.SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone STARTED
kafka.network.SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone PASSED
kafka.network.SocketServerTest > pollException STARTED
kafka.network.SocketServerTest > pollException PASSED
kafka.network.SocketServerTest > testSslSocketServer STARTED
kafka.network.SocketServerTest > testSslSocketServer PASSED
kafka.network.SocketServerTest > tooBigRequestIsRejected STARTED
kafka.network.SocketServerTest > tooBigRequestIsRejected PASSED
kafka.network.SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress STARTED
kafka.network.SocketServerTest > testNoOpActionResponseWithThrottledChannelWhereThrottlingInProgress PASSED
kafka.integration.MetricsDuringTopicCreationDeletionTest > classMethod STARTED
kafka.integration.MetricsDuringTopicCreationDeletionTest > classMethod FAILED
java.lang.AssertionError: Found unexpected threads during @BeforeClass, allThreads=Set(Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, scala-execution-context-global-222, kafka-request-handler-2, ThrottledChannelReaper-Request, Test worker, Test worker-SendThread(some.invalid.hostname.foo.bar.local:65535), /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 2, /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 3, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Thread-1303-EventThread, Signal Dispatcher, main, ExpirationReaper-0-DeleteRecords, ThrottledChannelReaper-Produce, Test worker-SendThread(localhost:41342), Test worker-SendThread(some.invalid.hostname.foo.bar.local:2181), Test worker-SendThread(localhost:50992), Thread-1303-SendThread(localhost:51283), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Common-Cleaner, Finalizer, ThrottledChannelReaper-Fetch, kafka-admin-client-thread | adminclient-135), unexpected=Set(kafka-admin-client-thread | adminclient-135)
kafka.integration.MetricsDuringTopicCreationDeletionTest > classMethod STARTED
kafka.integration.MetricsDuringTopicCreationDeletionTest > classMethod FAILED
java.lang.AssertionError: Found unexpected threads during @AfterClass, allThreads=Set(Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, scala-execution-context-global-222, kafka-request-handler-2, ThrottledChannelReaper-Request, Test worker, Test worker-SendThread(some.invalid.hostname.foo.bar.local:65535), /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 2, /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 3, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Thread-1303-EventThread, Signal Dispatcher, main, ExpirationReaper-0-DeleteRecords, ThrottledChannelReaper-Produce, Test worker-SendThread(localhost:41342), Test worker-SendThread(some.invalid.hostname.foo.bar.local:2181), Test worker-SendThread(localhost:50992), Thread-1303-SendThread(localhost:51283), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Common-Cleaner, Finalizer, ThrottledChannelReaper-Fetch, kafka-admin-client-thread | adminclient-135), unexpected=Set(kafka-admin-client-thread | adminclient-135)
kafka.integration.UncleanLeaderElectionTest > classMethod STARTED
kafka.integration.UncleanLeaderElectionTest > classMethod FAILED
java.lang.AssertionError: Found unexpected threads during @BeforeClass, allThreads=Set(Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, scala-execution-context-global-222, kafka-request-handler-2, ThrottledChannelReaper-Request, Test worker, Test worker-SendThread(some.invalid.hostname.foo.bar.local:65535), /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 2, /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 3, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Thread-1303-EventThread, Signal Dispatcher, main, ExpirationReaper-0-DeleteRecords, ThrottledChannelReaper-Produce, Test worker-SendThread(localhost:41342), Test worker-SendThread(some.invalid.hostname.foo.bar.local:2181), Test worker-SendThread(localhost:50992), Thread-1303-SendThread(localhost:51283), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Common-Cleaner, Finalizer, ThrottledChannelReaper-Fetch, kafka-admin-client-thread | adminclient-135), unexpected=Set(kafka-admin-client-thread | adminclient-135)
kafka.integration.UncleanLeaderElectionTest > classMethod STARTED
kafka.integration.UncleanLeaderElectionTest > classMethod FAILED
java.lang.AssertionError: Found unexpected threads during @AfterClass, allThreads=Set(Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, scala-execution-context-global-222, kafka-request-handler-2, ThrottledChannelReaper-Request, Test worker, Test worker-SendThread(some.invalid.hostname.foo.bar.local:65535), /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 2, /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 3, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Thread-1303-EventThread, Signal Dispatcher, main, ExpirationReaper-0-DeleteRecords, ThrottledChannelReaper-Produce, Test worker-SendThread(localhost:41342), Test worker-SendThread(some.invalid.hostname.foo.bar.local:2181), Test worker-SendThread(localhost:50992), Thread-1303-SendThread(localhost:51283), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Common-Cleaner, Finalizer, ThrottledChannelReaper-Fetch, kafka-admin-client-thread | adminclient-135), unexpected=Set(kafka-admin-client-thread | adminclient-135)
kafka.integration.MinIsrConfigTest > classMethod STARTED
kafka.integration.MinIsrConfigTest > classMethod FAILED
java.lang.AssertionError: Found unexpected threads during @BeforeClass, allThreads=Set(Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, scala-execution-context-global-222, kafka-request-handler-2, ThrottledChannelReaper-Request, Test worker, Test worker-SendThread(some.invalid.hostname.foo.bar.local:65535), /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 2, /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 3, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Thread-1303-EventThread, Signal Dispatcher, main, ExpirationReaper-0-DeleteRecords, ThrottledChannelReaper-Produce, Test worker-SendThread(localhost:41342), Test worker-SendThread(some.invalid.hostname.foo.bar.local:2181), Test worker-SendThread(localhost:50992), Thread-1303-SendThread(localhost:51283), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Common-Cleaner, Finalizer, ThrottledChannelReaper-Fetch, kafka-admin-client-thread | adminclient-135), unexpected=Set(kafka-admin-client-thread | adminclient-135)
kafka.integration.MinIsrConfigTest > classMethod STARTED
kafka.integration.MinIsrConfigTest > classMethod FAILED
java.lang.AssertionError: Found unexpected threads during @AfterClass, allThreads=Set(Reference Handler, ExpirationReaper-0-Produce, ReplicaFetcherThread-0-0, scala-execution-context-global-222, kafka-request-handler-2, ThrottledChannelReaper-Request, Test worker, Test worker-SendThread(some.invalid.hostname.foo.bar.local:65535), /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 2, /0:0:0:0:0:0:0:1:56736 to /0:0:0:0:0:0:0:1:47167 workers Thread 3, metrics-meter-tick-thread-1, metrics-meter-tick-thread-2, Thread-1303-EventThread, Signal Dispatcher, main, ExpirationReaper-0-DeleteRecords, ThrottledChannelReaper-Produce, Test worker-SendThread(localhost:41342), Test worker-SendThread(some.invalid.hostname.foo.bar.local:2181), Test worker-SendThread(localhost:50992), Thread-1303-SendThread(localhost:51283), Test worker-EventThread, shutdownable-thread-test, ExpirationReaper-0-Fetch, Common-Cleaner, Finalizer, ThrottledChannelReaper-Fetch, kafka-admin-client-thread | adminclient-135), unexpected=Set(kafka-admin-client-thread | adminclient-135)
1735 tests completed, 56 failed, 2 skipped
> Task :core:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':core:test'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/kafka-trunk-jdk10/ws/core/build/reports/tests/test/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
BUILD FAILED in 1h 0m 8s
39 actionable tasks: 17 executed, 22 up-to-date
Build step 'Execute shell' marked build as failure
Recording test results
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Not sending mail to unregistered user github@alasdairhodge.co.uk