See <https://builds.apache.org/job/kafka-trunk-jdk14/320/display/redirect?page=changes>
Changes: [github] KAFKA-10306: GlobalThread should fail on InvalidOffsetException (#9075) [github] MINOR: Recommend Java 11 (#9080) ------------------------------------------ [...truncated 2.80 MB...] org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldAssignEvenlyAcrossConsumersOneClientMultipleThreads[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldGetTime[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldGetTime[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowExceptionIfApplicationServerConfigPortIsNotAnInteger[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowExceptionIfApplicationServerConfigPortIsNotAnInteger[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldNotFailOnBranchedMultiLevelRepartitionConnectedTopology[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldNotFailOnBranchedMultiLevelRepartitionConnectedTopology[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowKafkaExceptionIfVersionProbingFlagConfigIsNotAtomicInteger[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowKafkaExceptionIfVersionProbingFlagConfigIsNotAtomicInteger[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowKafkaExceptionIfTaskMangerConfigIsNotTaskManagerInstance[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowKafkaExceptionIfTaskMangerConfigIsNotTaskManagerInstance[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldTriggerImmediateRebalanceOnHostInfoChange[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldTriggerImmediateRebalanceOnHostInfoChange[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldProduceMaximallyStickyAssignmentWhenMemberLeaves[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldProduceMaximallyStickyAssignmentWhenMemberLeaves[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldGetAssignmentConfigs[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldGetAssignmentConfigs[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowIfV2SubscriptionAndFutureSubscriptionIsMixed[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowIfV2SubscriptionAndFutureSubscriptionIsMixed[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldReturnInterleavedAssignmentWithUnrevokedPartitionsRemovedWhenNewConsumerJoins[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldReturnInterleavedAssignmentWithUnrevokedPartitionsRemovedWhenNewConsumerJoins[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignEmptyMetadata[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignEmptyMetadata[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldProduceStickyAndBalancedAssignmentWhenNewTasksAreAdded[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldProduceStickyAndBalancedAssignmentWhenNewTasksAreAdded[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowKafkaExceptionAssignmentErrorCodeNotConfigured[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowKafkaExceptionAssignmentErrorCodeNotConfigured[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldUseEagerRebalancingProtocol[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldUseEagerRebalancingProtocol[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignWithPartialTopology[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignWithPartialTopology[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignBasic[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignBasic[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testOnAssignment[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testOnAssignment[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldProduceStickyAndBalancedAssignmentWhenNothingChanges[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldProduceStickyAndBalancedAssignmentWhenNothingChanges[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignWithInternalTopicThatsSourceIsAnotherInternalTopic[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignWithInternalTopicThatsSourceIsAnotherInternalTopic[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldReturnLowestAssignmentVersionForDifferentSubscriptionVersionsV1V2[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldReturnLowestAssignmentVersionForDifferentSubscriptionVersionsV1V2[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldReturnLowestAssignmentVersionForDifferentSubscriptionVersionsV1V3[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldReturnLowestAssignmentVersionForDifferentSubscriptionVersionsV1V3[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldReturnLowestAssignmentVersionForDifferentSubscriptionVersionsV2V3[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldReturnLowestAssignmentVersionForDifferentSubscriptionVersionsV2V3[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignWithStandbyReplicasAndStatelessTasks[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignWithStandbyReplicasAndStatelessTasks[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testEagerSubscription[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testEagerSubscription[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowKafkaExceptionIfTaskMangerNotConfigured[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldThrowKafkaExceptionIfTaskMangerNotConfigured[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignWithInternalTopics[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testAssignWithInternalTopics[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testCooperativeSubscription[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > testCooperativeSubscription[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldNotAddStandbyTaskPartitionsToPartitionsForHost[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] STARTED org.apache.kafka.streams.processor.internals.StreamsPartitionAssignorTest > shouldNotAddStandbyTaskPartitionsToPartitionsForHost[task assignor = class org.apache.kafka.streams.processor.internals.assignment.FallbackPriorTaskAssignor] PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldThrowIllegalStateExceptionUponSetPartitionTimestampIfPartitionUnknown STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldThrowIllegalStateExceptionUponSetPartitionTimestampIfPartitionUnknown PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldThrowIllegalStateExceptionUponGetHeadRecordOffsetIfPartitionUnknown STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldThrowIllegalStateExceptionUponGetHeadRecordOffsetIfPartitionUnknown PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > testTimeTracking STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > testTimeTracking PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldUpdatePartitionQueuesShrinkAndExpand STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldUpdatePartitionQueuesShrinkAndExpand PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldEmptyPartitionsOnClear STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldEmptyPartitionsOnClear PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldSetPartitionTimestampAndStreamTime STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldSetPartitionTimestampAndStreamTime PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldThrowIllegalStateExceptionUponGetPartitionTimestampIfPartitionUnknown STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldThrowIllegalStateExceptionUponGetPartitionTimestampIfPartitionUnknown PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldUpdatePartitionQueuesExpand STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldUpdatePartitionQueuesExpand PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldChooseNextRecordBasedOnHeadTimestamp STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldChooseNextRecordBasedOnHeadTimestamp PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldThrowIllegalStateExceptionUponNumBufferedIfPartitionUnknown STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldThrowIllegalStateExceptionUponNumBufferedIfPartitionUnknown PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldThrowIllegalStateExceptionUponAddRecordsIfPartitionUnknown STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldThrowIllegalStateExceptionUponAddRecordsIfPartitionUnknown PASSED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldUpdatePartitionQueuesShrink STARTED org.apache.kafka.streams.processor.internals.PartitionGroupTest > shouldUpdatePartitionQueuesShrink PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldProcessRecordsForTopic STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldProcessRecordsForTopic PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldInitializeProcessorTopology STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldInitializeProcessorTopology PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldWipeGlobalStateDirectory STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldWipeGlobalStateDirectory PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldInitializeContext STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldInitializeContext PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldCheckpointOffsetsWhenStateIsFlushed STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldCheckpointOffsetsWhenStateIsFlushed PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldThrowStreamsExceptionWhenKeyDeserializationFails STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldThrowStreamsExceptionWhenKeyDeserializationFails PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldInitializeStateManager STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldInitializeStateManager PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldProcessRecordsForOtherTopic STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldProcessRecordsForOtherTopic PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldNotThrowStreamsExceptionWhenValueDeserializationFails STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldNotThrowStreamsExceptionWhenValueDeserializationFails PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldThrowStreamsExceptionWhenValueDeserializationFails STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldThrowStreamsExceptionWhenValueDeserializationFails PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldFlushStateManagerWithOffsets STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldFlushStateManagerWithOffsets PASSED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldNotThrowStreamsExceptionWhenKeyDeserializationFailsWithSkipHandler STARTED org.apache.kafka.streams.processor.internals.GlobalStateTaskTest > shouldNotThrowStreamsExceptionWhenKeyDeserializationFailsWithSkipHandler PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldStayDeadAfterTwoCloses STARTED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldStayDeadAfterTwoCloses PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldTransitionToRunningOnStart STARTED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldTransitionToRunningOnStart PASSED org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest > shouldDieOnInvalidOffsetExceptionDuringStartup STARTED ERROR: No tool found matching GRADLE_4_10_2_HOME ERROR: Could not install GRADLE_4_10_3_HOME java.lang.NullPointerException ERROR: No tool found matching GRADLE_4_10_2_HOME ERROR: Could not install GRADLE_4_10_3_HOME java.lang.NullPointerException ERROR: No tool found matching GRADLE_4_10_2_HOME ERROR: Could not install GRADLE_4_10_3_HOME java.lang.NullPointerException ERROR: No tool found matching GRADLE_4_10_2_HOME ERROR: Could not install GRADLE_4_10_3_HOME java.lang.NullPointerException ERROR: No tool found matching GRADLE_4_10_2_HOME ERROR: Could not install GRADLE_4_10_3_HOME java.lang.NullPointerException ERROR: No tool found matching GRADLE_4_10_2_HOME ERROR: Could not install GRADLE_4_10_3_HOME java.lang.NullPointerException ERROR: No tool found matching GRADLE_4_10_2_HOME ERROR: Could not install GRADLE_4_10_3_HOME java.lang.NullPointerException Build timed out (after 480 minutes). Marking the build as failed. Build was aborted Recording test results ERROR: No tool found matching GRADLE_4_10_2_HOME Setting GRADLE_4_10_3_HOME=/home/jenkins/tools/gradle/4.10.3 ERROR: No tool found matching GRADLE_4_10_2_HOME Setting GRADLE_4_10_3_HOME=/home/jenkins/tools/gradle/4.10.3 Not sending mail to unregistered user nore...@github.com
