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 > > >
