Build failed in Jenkins: kafka-trunk-jdk7 #3301

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://builds.apache.org/job/kafka-trunk-jdk7/3301/display/redirect?page=changes>

Changes:

[junrao] KAFKA-6630: Speed up the processing of

------------------------------------------
[...truncated 1.93 MB...]
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 > testEncodeDecode STARTED

org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > testEncodeDecode PASSED

org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldDecodePreviousVersion STARTED

org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > shouldDecodePreviousVersion 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 > testEncodeDecode STARTED

org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > testEncodeDecode PASSED

org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeDecodeWithUserEndPoint STARTED

org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldEncodeDecodeWithUserEndPoint PASSED

org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldBeBackwardCompatible STARTED

org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > shouldBeBackwardCompatible 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

1905 tests completed, 5 failed
: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-jdk7/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.5.1/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 2h 11m 52s
54 actionable tasks: 32 executed, 22 up-to-date
Build step 'Execute shell' marked build as failure
[FINDBUGS] Collecting findbugs analysis files...
Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5
[FINDBUGS] Searching for all files in <https://builds.apache.org/job/kafka-trunk-jdk7/ws/> that match the pattern **/build/reports/findbugs/*.xml
[FINDBUGS] Parsing 5 files in <https://builds.apache.org/job/kafka-trunk-jdk7/ws/>
[FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-trunk-jdk7/ws/clients/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-trunk-jdk7/ws/core/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-trunk-jdk7/ws/examples/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-trunk-jdk7/ws/log4j-appender/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-trunk-jdk7/ws/streams/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates.
Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5
Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5
<Git Blamer> Using GitBlamer to create author and commit information for all warnings.
<Git Blamer> GIT_COMMIT=2ef6ee2338178c7501f5bd4c7cce5f4cea9d3e17, workspace=<https://builds.apache.org/job/kafka-trunk-jdk7/ws/>
[FINDBUGS] Computing warning deltas based on reference build #3300
Recording test results
Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5
Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5

Jenkins build is back to normal : kafka-trunk-jdk7 #3302

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://builds.apache.org/job/kafka-trunk-jdk7/3302/display/redirect?page=changes>