Yeah it's was all good in the end :) Thanks Ted
On Thu, 23 Aug 2018 at 21:42 Ted Yu <yuzhih...@gmail.com> wrote: > I ran streams unit tests as of > commit 4156ea0a9bcca67d209fd3b43d2268c9abd5a0b5 . > > All tests passed locally. > > FYI > > On Thu, Aug 23, 2018 at 12:23 PM Joan Goyeau <j...@goyeau.com> wrote: > > > 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 > > > > > >
