See
<https://builds.apache.org/job/kafka-trunk-jdk14/323/display/redirect?page=changes>
Changes:
[github] MINOR: Adjust 'release.py' script to use shell when using gradlewAll
and
[github] MINOR: Remove staticmethod tag to be able to use logger of instance
[github] MINOR: remove NewTopic#NO_PARTITIONS and NewTopic#NO_REPLICATION_FACTOR
------------------------------------------
[...truncated 2.81 MB...]
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
at
hudson.plugins.toolenv.ToolEnvBuildWrapper$1.buildEnvVars(ToolEnvBuildWrapper.java:46)
at hudson.model.AbstractBuild.getEnvironment(AbstractBuild.java:873)
at hudson.plugins.git.GitSCM.getParamExpandedRepos(GitSCM.java:484)
at
hudson.plugins.git.GitSCM.compareRemoteRevisionWithImpl(GitSCM.java:693)
at hudson.plugins.git.GitSCM.compareRemoteRevisionWith(GitSCM.java:658)
at hudson.scm.SCM.compareRemoteRevisionWith(SCM.java:400)
at hudson.scm.SCM.poll(SCM.java:417)
at hudson.model.AbstractProject._poll(AbstractProject.java:1390)
at hudson.model.AbstractProject.poll(AbstractProject.java:1293)
at hudson.triggers.SCMTrigger$Runner.runPolling(SCMTrigger.java:603)
at hudson.triggers.SCMTrigger$Runner.run(SCMTrigger.java:649)
at
hudson.util.SequentialExecutionQueue$QueueEntry.run(SequentialExecutionQueue.java:119)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
ERROR: No tool found matching GRADLE_4_10_2_HOME
ERROR: Could not install GRADLE_4_10_3_HOME
java.lang.NullPointerException
at
hudson.plugins.toolenv.ToolEnvBuildWrapper$1.buildEnvVars(ToolEnvBuildWrapper.java:46)
at hudson.model.AbstractBuild.getEnvironment(AbstractBuild.java:873)
at hudson.plugins.git.GitSCM.getParamExpandedRepos(GitSCM.java:484)
at
hudson.plugins.git.GitSCM.compareRemoteRevisionWithImpl(GitSCM.java:693)
at hudson.plugins.git.GitSCM.compareRemoteRevisionWith(GitSCM.java:658)
at hudson.scm.SCM.compareRemoteRevisionWith(SCM.java:400)
at hudson.scm.SCM.poll(SCM.java:417)
at hudson.model.AbstractProject._poll(AbstractProject.java:1390)
at hudson.model.AbstractProject.poll(AbstractProject.java:1293)
at hudson.triggers.SCMTrigger$Runner.runPolling(SCMTrigger.java:603)
at hudson.triggers.SCMTrigger$Runner.run(SCMTrigger.java:649)
at
hudson.util.SequentialExecutionQueue$QueueEntry.run(SequentialExecutionQueue.java:119)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
ERROR: No tool found matching GRADLE_4_10_2_HOME
ERROR: Could not install GRADLE_4_10_3_HOME
java.lang.NullPointerException
at
hudson.plugins.toolenv.ToolEnvBuildWrapper$1.buildEnvVars(ToolEnvBuildWrapper.java:46)
at hudson.model.AbstractBuild.getEnvironment(AbstractBuild.java:873)
at hudson.plugins.git.GitSCM.getParamExpandedRepos(GitSCM.java:484)
at
hudson.plugins.git.GitSCM.compareRemoteRevisionWithImpl(GitSCM.java:693)
at hudson.plugins.git.GitSCM.compareRemoteRevisionWith(GitSCM.java:658)
at hudson.scm.SCM.compareRemoteRevisionWith(SCM.java:400)
at hudson.scm.SCM.poll(SCM.java:417)
at hudson.model.AbstractProject._poll(AbstractProject.java:1390)
at hudson.model.AbstractProject.poll(AbstractProject.java:1293)
at hudson.triggers.SCMTrigger$Runner.runPolling(SCMTrigger.java:603)
at hudson.triggers.SCMTrigger$Runner.run(SCMTrigger.java:649)
at
hudson.util.SequentialExecutionQueue$QueueEntry.run(SequentialExecutionQueue.java:119)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
ERROR: No tool found matching GRADLE_4_10_2_HOME
ERROR: Could not install GRADLE_4_10_3_HOME
java.lang.NullPointerException
at
hudson.plugins.toolenv.ToolEnvBuildWrapper$1.buildEnvVars(ToolEnvBuildWrapper.java:46)
at hudson.model.AbstractBuild.getEnvironment(AbstractBuild.java:873)
at hudson.plugins.git.GitSCM.getParamExpandedRepos(GitSCM.java:484)
at
hudson.plugins.git.GitSCM.compareRemoteRevisionWithImpl(GitSCM.java:693)
at hudson.plugins.git.GitSCM.compareRemoteRevisionWith(GitSCM.java:658)
at hudson.scm.SCM.compareRemoteRevisionWith(SCM.java:400)
at hudson.scm.SCM.poll(SCM.java:417)
at hudson.model.AbstractProject._poll(AbstractProject.java:1390)
at hudson.model.AbstractProject.poll(AbstractProject.java:1293)
at hudson.triggers.SCMTrigger$Runner.runPolling(SCMTrigger.java:603)
at hudson.triggers.SCMTrigger$Runner.run(SCMTrigger.java:649)
at
hudson.util.SequentialExecutionQueue$QueueEntry.run(SequentialExecutionQueue.java:119)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
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
org.apache.kafka.streams.processor.internals.GlobalStreamThreadTest >
shouldDieOnInvalidOffsetExceptionDuringStartup SKIPPED
Not sending mail to unregistered user [email protected]