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/19 09:48:23 UTC
Build failed in Jenkins: kafka-trunk-jdk10 #291
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
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