I'm looking into this one. On Thu, 23 Aug 2018 at 20:19 Apache Jenkins Server < jenk...@builds.apache.org> wrote:
> See < > https://builds.apache.org/job/kafka-trunk-jdk10/429/display/redirect?page=changes > > > > Changes: > > [wangguoz] KAFKA-7316: Fix Streams Scala filter recursive call #5538 > > ------------------------------------------ > [...truncated 1.98 MB...] > 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 > > shouldEncodeAndDecodeVersion4 STARTED > > org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest > > shouldEncodeAndDecodeVersion4 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 > > shouldEncodeAndDecodeVersion4 STARTED > > org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest > > shouldEncodeAndDecodeVersion4 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 > pure virtual method called > terminate called without an active exception > > > 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 10m 54s > 67 actionable tasks: 46 executed, 21 up-to-date > Build step 'Execute shell' marked build as failure > Recording test results > Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1 > Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1 > Not sending mail to unregistered user wangg...@gmail.com >
