See <https://builds.apache.org/job/kafka-trunk-jdk7/1526/changes>
Changes:
[jason] KAFKA-4139; Reset findCoordinatorFuture when brokers are unavailable
------------------------------------------
[...truncated 12297 lines...]
org.apache.kafka.streams.processor.internals.PartitionGroupTest >
testTimeTracking PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest >
testInjectClients STARTED
org.apache.kafka.streams.processor.internals.StreamThreadTest >
testInjectClients PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testMaybeCommit
STARTED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testMaybeCommit
PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest >
testPartitionAssignmentChange STARTED
org.apache.kafka.streams.processor.internals.StreamThreadTest >
testPartitionAssignmentChange PASSED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testMaybeClean
STARTED
org.apache.kafka.streams.processor.internals.StreamThreadTest > testMaybeClean
PASSED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest >
testTracking STARTED
org.apache.kafka.streams.processor.internals.MinTimestampTrackerTest >
testTracking PASSED
org.apache.kafka.streams.processor.internals.StreamTaskTest > testProcessOrder
STARTED
org.apache.kafka.streams.processor.internals.StreamTaskTest > testProcessOrder
PASSED
org.apache.kafka.streams.processor.internals.StreamTaskTest > testPauseResume
STARTED
org.apache.kafka.streams.processor.internals.StreamTaskTest > testPauseResume
PASSED
org.apache.kafka.streams.processor.internals.StreamTaskTest >
testMaybePunctuate STARTED
org.apache.kafka.streams.processor.internals.StreamTaskTest >
testMaybePunctuate PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest >
testEncodeDecode STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest >
testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest >
shouldDecodePreviousVersion STARTED
org.apache.kafka.streams.processor.internals.assignment.AssignmentInfoTest >
shouldDecodePreviousVersion PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest >
testEncodeDecode STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest >
testEncodeDecode PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest >
shouldEncodeDecodeWithUserEndPoint STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest >
shouldEncodeDecodeWithUserEndPoint PASSED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest >
shouldBeBackwardCompatible STARTED
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest >
shouldBeBackwardCompatible PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest >
testStickiness STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest >
testStickiness PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest >
testAssignWithStandby STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest >
testAssignWithStandby PASSED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest >
testAssignWithoutStandby STARTED
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorTest >
testAssignWithoutStandby PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testDrivingMultiplexingTopology STARTED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testDrivingMultiplexingTopology PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testDrivingStatefulTopology STARTED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testDrivingStatefulTopology PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testDrivingSimpleTopology STARTED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testDrivingSimpleTopology PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testDrivingSimpleMultiSourceTopology STARTED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testDrivingSimpleMultiSourceTopology PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testTopologyMetadata STARTED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testTopologyMetadata PASSED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testDrivingMultiplexByNameTopology STARTED
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest >
testDrivingMultiplexByNameTopology PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest >
testSpecificPartition STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest >
testSpecificPartition PASSED
org.apache.kafka.streams.processor.internals.RecordCollectorTest >
testStreamPartitioner STARTED
org.apache.kafka.streams.processor.internals.RecordCollectorTest >
testStreamPartitioner PASSED
org.apache.kafka.streams.processor.internals.PunctuationQueueTest >
testPunctuationInterval STARTED
org.apache.kafka.streams.processor.internals.PunctuationQueueTest >
testPunctuationInterval PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldThrowExceptionIfApplicationServerConfigIsNotHostPortPair STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldThrowExceptionIfApplicationServerConfigIsNotHostPortPair PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldMapUserEndPointToTopicPartitions STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldMapUserEndPointToTopicPartitions PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldAddUserDefinedEndPointToSubscription STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldAddUserDefinedEndPointToSubscription PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignWithStandbyReplicas STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignWithStandbyReplicas PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignWithNewTasks STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignWithNewTasks PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldExposeHostStateToTopicPartitionsOnAssignment STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldExposeHostStateToTopicPartitionsOnAssignment PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignWithStates STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignWithStates PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldThrowExceptionIfApplicationServerConfigPortIsNotAnInteger STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldThrowExceptionIfApplicationServerConfigPortIsNotAnInteger PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldReturnEmptyClusterMetadataIfItHasntBeenBuilt STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldReturnEmptyClusterMetadataIfItHasntBeenBuilt PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignBasic STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignBasic PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testOnAssignment STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testOnAssignment PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignWithInternalTopicThatsSourceIsAnotherInternalTopic STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignWithInternalTopicThatsSourceIsAnotherInternalTopic PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testSubscription STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testSubscription PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldSetClusterMetadataOnAssignment STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
shouldSetClusterMetadataOnAssignment PASSED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignWithInternalTopics STARTED
org.apache.kafka.streams.processor.internals.StreamPartitionAssignorTest >
testAssignWithInternalTopics PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetInstancesForStoreName STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetInstancesForStoreName PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldThrowWhenSerializerIsNull STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldThrowWhenSerializerIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetAllStreamInstances STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetAllStreamInstances PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetInstanceWithKey STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetInstanceWithKey PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetAllStreamsInstancesWithNoStores STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetAllStreamsInstancesWithNoStores PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldThrowWhenKeyIsNull STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldThrowWhenKeyIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetInstanceWithKeyWithMergedStreams STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetInstanceWithKeyWithMergedStreams PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldThrowIfStoreNameIsNull STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldThrowIfStoreNameIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldReturnEmptyCollectionOnGetAllInstancesWithStoreWhenStoreDoesntExist
STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldReturnEmptyCollectionOnGetAllInstancesWithStoreWhenStoreDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldReturnNullOnGetWithKeyWhenStoreDoesntExist STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldReturnNullOnGetWithKeyWhenStoreDoesntExist PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldThrowIfStreamPartitionerIsNull STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldThrowIfStreamPartitionerIsNull PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetInstanceWithKeyAndCustomPartitioner STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldGetInstanceWithKeyAndCustomPartitioner PASSED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldThrowIfStoreNameIsNullOnGetAllInstancesWithStore STARTED
org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest >
shouldThrowIfStoreNameIsNullOnGetAllInstancesWithStore PASSED
org.apache.kafka.streams.KafkaStreamsTest > classMethod STARTED
org.apache.kafka.streams.KafkaStreamsTest > classMethod FAILED
java.lang.NoSuchMethodError:
scala.Predef$.$conforms()Lscala/Predef$$less$colon$less;
at kafka.utils.MockScheduler.<init>(MockScheduler.scala:38)
at kafka.utils.MockTime.<init>(MockTime.scala:35)
at kafka.utils.MockTime.<init>(MockTime.scala:37)
at
org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster.<init>(EmbeddedKafkaCluster.java:44)
at
org.apache.kafka.streams.KafkaStreamsTest.<clinit>(KafkaStreamsTest.java:42)
org.apache.kafka.streams.KeyValueTest > shouldHaveSaneEqualsAndHashCode STARTED
org.apache.kafka.streams.KeyValueTest > shouldHaveSaneEqualsAndHashCode PASSED
pure virtual method called
terminate called without an active exception
355 tests completed, 9 failed
:streams:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':streams:test'.
> Process 'Gradle Test Executor 4' finished with non-zero exit value 134
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output.
BUILD FAILED
Total time: 2 hrs 46 mins 8.926 secs
Build step 'Execute shell' marked build as failure
Recording test results
Setting
GRADLE_2_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_2.4-rc-2
Setting
GRADLE_2_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_2.4-rc-2
