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 lindon...@gmail.com Not sending mail to unregistered user git...@alasdairhodge.co.uk
