See
<https://builds.apache.org/job/kafka-trunk-jdk8/1323/display/redirect?page=changes>
Changes:
[becket.qin] KAFKA-4820; ConsumerNetworkClient.send() should not require global
lock
------------------------------------------
[...truncated 100.67 KB...]
kafka.api.PlaintextConsumerTest > testEarliestOrLatestOffsets STARTED
kafka.api.PlaintextConsumerTest > testEarliestOrLatestOffsets PASSED
kafka.api.PlaintextConsumerTest > testPartitionsForAutoCreate STARTED
kafka.api.PlaintextConsumerTest > testPartitionsForAutoCreate PASSED
kafka.api.PlaintextConsumerTest > testShrinkingTopicSubscriptions STARTED
kafka.api.PlaintextConsumerTest > testShrinkingTopicSubscriptions PASSED
kafka.api.PlaintextConsumerTest > testMaxPollIntervalMs STARTED
kafka.api.PlaintextConsumerTest > testMaxPollIntervalMs PASSED
kafka.api.PlaintextConsumerTest > testOffsetsForTimes STARTED
kafka.api.PlaintextConsumerTest > testOffsetsForTimes PASSED
kafka.api.PlaintextConsumerTest > testSubsequentPatternSubscription STARTED
kafka.api.PlaintextConsumerTest > testSubsequentPatternSubscription PASSED
kafka.api.PlaintextConsumerTest > testAsyncCommit STARTED
kafka.api.PlaintextConsumerTest > testAsyncCommit PASSED
kafka.api.PlaintextConsumerTest > testLowMaxFetchSizeForRequestAndPartition
STARTED
kafka.api.PlaintextConsumerTest > testLowMaxFetchSizeForRequestAndPartition
PASSED
kafka.api.PlaintextConsumerTest > testMultiConsumerSessionTimeoutOnStopPolling
STARTED
kafka.api.PlaintextConsumerTest > testMultiConsumerSessionTimeoutOnStopPolling
FAILED
java.lang.AssertionError: Did not get valid initial assignment for
partitions [topic1-2, topic1-4, topic-1, topic-0, topic1-0, topic1-3, topic1-5,
topic1-1]
at kafka.utils.TestUtils$.fail(TestUtils.scala:307)
at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:793)
at
kafka.api.PlaintextConsumerTest.validateGroupAssignment(PlaintextConsumerTest.scala:1486)
at
kafka.api.PlaintextConsumerTest.runMultiConsumerSessionTimeoutTest(PlaintextConsumerTest.scala:1353)
at
kafka.api.PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling(PlaintextConsumerTest.scala:831)
java.util.ConcurrentModificationException: KafkaConsumer is not safe for
multi-threaded access
kafka.api.PlaintextConsumerTest > testMaxPollIntervalMsDelayInRevocation STARTED
kafka.api.PlaintextConsumerTest > testMaxPollIntervalMsDelayInRevocation PASSED
kafka.api.PlaintextConsumerTest > testPerPartitionLagMetricsCleanUpWithAssign
STARTED
kafka.api.PlaintextConsumerTest > testPerPartitionLagMetricsCleanUpWithAssign
PASSED
kafka.api.PlaintextConsumerTest > testPartitionsForInvalidTopic STARTED
kafka.api.PlaintextConsumerTest > testPartitionsForInvalidTopic PASSED
kafka.api.PlaintextConsumerTest > testPauseStateNotPreservedByRebalance STARTED
kafka.api.PlaintextConsumerTest > testPauseStateNotPreservedByRebalance PASSED
kafka.api.PlaintextConsumerTest >
testFetchHonoursFetchSizeIfLargeRecordNotFirst STARTED
kafka.api.PlaintextConsumerTest >
testFetchHonoursFetchSizeIfLargeRecordNotFirst PASSED
kafka.api.PlaintextConsumerTest > testSeek STARTED
kafka.api.PlaintextConsumerTest > testSeek PASSED
kafka.api.PlaintextConsumerTest > testPositionAndCommit STARTED
kafka.api.PlaintextConsumerTest > testPositionAndCommit PASSED
kafka.api.PlaintextConsumerTest >
testFetchRecordLargerThanMaxPartitionFetchBytes STARTED
kafka.api.PlaintextConsumerTest >
testFetchRecordLargerThanMaxPartitionFetchBytes PASSED
kafka.api.PlaintextConsumerTest > testUnsubscribeTopic STARTED
kafka.api.PlaintextConsumerTest > testUnsubscribeTopic FAILED
java.lang.IllegalStateException: No entry found for connection 0
kafka.api.PlaintextConsumerTest > testMultiConsumerSessionTimeoutOnClose STARTED
kafka.api.PlaintextConsumerTest > testMultiConsumerSessionTimeoutOnClose PASSED
kafka.api.PlaintextConsumerTest > testFetchRecordLargerThanFetchMaxBytes STARTED
kafka.api.PlaintextConsumerTest > testFetchRecordLargerThanFetchMaxBytes PASSED
kafka.api.PlaintextConsumerTest > testMultiConsumerDefaultAssignment STARTED
kafka.api.PlaintextConsumerTest > testMultiConsumerDefaultAssignment PASSED
kafka.api.PlaintextConsumerTest > testAutoCommitOnClose STARTED
kafka.api.PlaintextConsumerTest > testAutoCommitOnClose PASSED
kafka.api.PlaintextConsumerTest > testListTopics STARTED
kafka.api.PlaintextConsumerTest > testListTopics PASSED
kafka.api.PlaintextConsumerTest > testExpandingTopicSubscriptions STARTED
kafka.api.PlaintextConsumerTest > testExpandingTopicSubscriptions PASSED
kafka.api.PlaintextConsumerTest > testInterceptors STARTED
kafka.api.PlaintextConsumerTest > testInterceptors PASSED
kafka.api.PlaintextConsumerTest > testPatternUnsubscription STARTED
kafka.api.PlaintextConsumerTest > testPatternUnsubscription PASSED
kafka.api.PlaintextConsumerTest > testGroupConsumption STARTED
kafka.api.PlaintextConsumerTest > testGroupConsumption PASSED
kafka.api.PlaintextConsumerTest > testPartitionsFor STARTED
kafka.api.PlaintextConsumerTest > testPartitionsFor PASSED
kafka.api.PlaintextConsumerTest > testAutoCommitOnRebalance STARTED
kafka.api.PlaintextConsumerTest > testAutoCommitOnRebalance PASSED
kafka.api.PlaintextConsumerTest > testInterceptorsWithWrongKeyValue STARTED
kafka.api.PlaintextConsumerTest > testInterceptorsWithWrongKeyValue PASSED
kafka.api.PlaintextConsumerTest > testMaxPollIntervalMsDelayInAssignment STARTED
kafka.api.PlaintextConsumerTest > testMaxPollIntervalMsDelayInAssignment PASSED
kafka.api.PlaintextConsumerTest > testMultiConsumerRoundRobinAssignment STARTED
kafka.api.PlaintextConsumerTest > testMultiConsumerRoundRobinAssignment PASSED
kafka.api.PlaintextConsumerTest > testPartitionPauseAndResume STARTED
kafka.api.PlaintextConsumerTest > testPartitionPauseAndResume PASSED
kafka.api.PlaintextConsumerTest >
testPerPartitionLagMetricsCleanUpWithSubscribe STARTED
kafka.api.PlaintextConsumerTest >
testPerPartitionLagMetricsCleanUpWithSubscribe PASSED
kafka.api.PlaintextConsumerTest > testConsumeMessagesWithLogAppendTime STARTED
kafka.api.PlaintextConsumerTest > testConsumeMessagesWithLogAppendTime PASSED
kafka.api.PlaintextConsumerTest > testAutoCommitOnCloseAfterWakeup STARTED
kafka.api.PlaintextConsumerTest > testAutoCommitOnCloseAfterWakeup PASSED
kafka.api.PlaintextConsumerTest > testMaxPollRecords STARTED
kafka.api.PlaintextConsumerTest > testMaxPollRecords PASSED
kafka.api.PlaintextConsumerTest > testAutoOffsetReset STARTED
kafka.api.PlaintextConsumerTest > testAutoOffsetReset PASSED
kafka.api.PlaintextConsumerTest > testPerPartitionLagWithMaxPollRecords STARTED
kafka.api.PlaintextConsumerTest > testPerPartitionLagWithMaxPollRecords PASSED
kafka.api.PlaintextConsumerTest > testFetchInvalidOffset STARTED
kafka.api.PlaintextConsumerTest > testFetchInvalidOffset PASSED
kafka.api.PlaintextConsumerTest > testAutoCommitIntercept STARTED
kafka.api.PlaintextConsumerTest > testAutoCommitIntercept PASSED
kafka.api.PlaintextConsumerTest >
testFetchHonoursMaxPartitionFetchBytesIfLargeRecordNotFirst STARTED
kafka.api.PlaintextConsumerTest >
testFetchHonoursMaxPartitionFetchBytesIfLargeRecordNotFirst PASSED
kafka.api.PlaintextConsumerTest > testCommitSpecifiedOffsets STARTED
kafka.api.PlaintextConsumerTest > testCommitSpecifiedOffsets PASSED
kafka.api.PlaintextConsumerTest > testCommitMetadata STARTED
kafka.api.PlaintextConsumerTest > testCommitMetadata PASSED
kafka.api.PlaintextConsumerTest > testRoundRobinAssignment STARTED
kafka.api.PlaintextConsumerTest > testRoundRobinAssignment PASSED
kafka.api.PlaintextConsumerTest > testPatternSubscription STARTED
kafka.api.PlaintextConsumerTest > testPatternSubscription PASSED
kafka.api.PlaintextConsumerTest > testCoordinatorFailover STARTED
kafka.api.PlaintextConsumerTest > testCoordinatorFailover PASSED
kafka.api.PlaintextConsumerTest > testSimpleConsumption STARTED
kafka.api.PlaintextConsumerTest > testSimpleConsumption PASSED
kafka.api.ConsumerBounceTest > testCloseDuringRebalance STARTED
kafka.api.ConsumerBounceTest > testCloseDuringRebalance PASSED
kafka.api.ConsumerBounceTest > testClose STARTED
kafka.api.ConsumerBounceTest > testClose PASSED
kafka.api.ConsumerBounceTest > testSeekAndCommitWithBrokerFailures STARTED
kafka.api.ConsumerBounceTest > testSeekAndCommitWithBrokerFailures PASSED
kafka.api.ConsumerBounceTest > testSubscribeWhenTopicUnavailable STARTED
kafka.api.ConsumerBounceTest > testSubscribeWhenTopicUnavailable PASSED
kafka.api.ConsumerBounceTest > testConsumptionWithBrokerFailures STARTED
kafka.api.ConsumerBounceTest > testConsumptionWithBrokerFailures FAILED
java.lang.IllegalArgumentException: You can only check the position for
partitions assigned to this consumer.
at
org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1265)
at
kafka.api.ConsumerBounceTest.consumeWithBrokerFailures(ConsumerBounceTest.scala:111)
at
kafka.api.ConsumerBounceTest.testConsumptionWithBrokerFailures(ConsumerBounceTest.scala:84)
kafka.api.test.ProducerCompressionTest > testCompression[0] STARTED
664 tests completed, 3 failed
:kafka-trunk-jdk8:core:test FAILED
:test_core_2_10 FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':core:test'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 1
* 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: 32 mins 29.116 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
ERROR: Step ‘Publish JUnit test result report’ failed: No test report files
were found. Configuration error?
Setting
GRADLE_2_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_2.4-rc-2
