See <https://builds.apache.org/job/Kafka-trunk/623/changes>
Changes:
[jjkoshy] KAFKA-2120; Add a request timeout to NetworkClient (KIP-19); reviewed
by Jason Gustafson, Ismael Juma, Joel Koshy, Jun Rao, and Edward Ribeiro
------------------------------------------
[...truncated 1824 lines...]
kafka.server.LogRecoveryTest > testHWCheckpointWithFailuresSingleLogSegment
PASSED
kafka.coordinator.PartitionAssignorTest >
testRoundRobinAssignorOneConsumerNonexistentTopic PASSED
kafka.coordinator.PartitionAssignorTest >
testRangeAssignorOnlyAssignsPartitionsFromSubscribedTopics PASSED
kafka.coordinator.PartitionAssignorTest > testRangeAssignorOneConsumerNoTopic
PASSED
kafka.coordinator.PartitionAssignorTest >
testRangeAssignorOneConsumerMultipleTopics PASSED
kafka.coordinator.PartitionAssignorTest >
testRoundRobinAssignorOnlyAssignsPartitionsFromSubscribedTopics PASSED
kafka.coordinator.PartitionAssignorTest >
testRoundRobinAssignorTwoConsumersOneTopicOnePartition PASSED
kafka.coordinator.PartitionAssignorTest >
testRangeAssignorTwoConsumersOneTopicTwoPartitions PASSED
kafka.coordinator.PartitionAssignorTest >
testRoundRobinAssignorTwoConsumersOneTopicTwoPartitions PASSED
kafka.coordinator.PartitionAssignorTest >
testRoundRobinAssignorMultipleConsumersMixedTopics PASSED
kafka.coordinator.PartitionAssignorTest >
testRangeAssignorTwoConsumersOneTopicOnePartition PASSED
kafka.coordinator.PartitionAssignorTest >
testRangeAssignorMultipleConsumersMixedTopics PASSED
kafka.coordinator.PartitionAssignorTest >
testRoundRobinAssignorOneConsumerNoTopic PASSED
kafka.coordinator.PartitionAssignorTest >
testRoundRobinAssignorOneConsumerOneTopic PASSED
kafka.coordinator.PartitionAssignorTest > testRangeAssignorOneConsumerOneTopic
PASSED
kafka.coordinator.PartitionAssignorTest >
testRangeAssignorOneConsumerNonexistentTopic PASSED
kafka.coordinator.PartitionAssignorTest >
testRoundRobinAssignorOneConsumerMultipleTopics PASSED
kafka.coordinator.PartitionAssignorTest >
testRoundRobinAssignorTwoConsumersTwoTopicsSixPartitions PASSED
kafka.coordinator.PartitionAssignorTest >
testRangeAssignorTwoConsumersTwoTopicsSixPartitions PASSED
kafka.tools.ConsoleProducerTest > testParseKeyProp PASSED
kafka.tools.ConsoleProducerTest > testValidConfigsOldProducer PASSED
kafka.tools.ConsoleProducerTest > testInvalidConfigs PASSED
kafka.tools.ConsoleProducerTest > testValidConfigsNewProducer PASSED
kafka.admin.ConfigCommandTest > testArgumentParse PASSED
kafka.admin.DeleteTopicTest > testDeleteTopicWithAllAliveReplicas PASSED
kafka.admin.DeleteTopicTest > testDeleteTopicDuringAddPartition PASSED
kafka.api.ConsumerTest > testPatternUnsubscription PASSED
kafka.api.ConsumerTest > testGroupConsumption PASSED
kafka.api.ConsumerTest > testPartitionsFor PASSED
kafka.api.ConsumerTest > testSimpleConsumption FAILED
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.NetworkException: The server disconnected before
a response was received.
at
org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:56)
at
org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:43)
at
org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:25)
at
kafka.api.ConsumerTest$$anonfun$sendRecords$1.apply(ConsumerTest.scala:449)
at
kafka.api.ConsumerTest$$anonfun$sendRecords$1.apply(ConsumerTest.scala:449)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.Iterator$class.foreach(Iterator.scala:727)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
at scala.collection.AbstractTraversable.map(Traversable.scala:105)
at kafka.api.ConsumerTest.sendRecords(ConsumerTest.scala:449)
at kafka.api.ConsumerTest.sendRecords(ConsumerTest.scala:442)
at kafka.api.ConsumerTest.testSimpleConsumption(ConsumerTest.scala:73)
Caused by:
org.apache.kafka.common.errors.NetworkException: The server
disconnected before a response was received.
kafka.api.ConsumerTest > testPartitionPauseAndResume PASSED
kafka.api.ConsumerTest > testPartitionReassignmentCallback PASSED
kafka.api.ConsumerTest > testAutoOffsetReset PASSED
kafka.api.ConsumerTest > testCommitSpecifiedOffsets PASSED
kafka.api.ConsumerTest > testPatternSubscription FAILED
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.NetworkException: The server disconnected before
a response was received.
at
org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:56)
at
org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:43)
at
org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:25)
at
kafka.api.ConsumerTest$$anonfun$sendRecords$1.apply(ConsumerTest.scala:449)
at
kafka.api.ConsumerTest$$anonfun$sendRecords$1.apply(ConsumerTest.scala:449)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.Iterator$class.foreach(Iterator.scala:727)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
at scala.collection.AbstractTraversable.map(Traversable.scala:105)
at kafka.api.ConsumerTest.sendRecords(ConsumerTest.scala:449)
at kafka.api.ConsumerTest.sendRecords(ConsumerTest.scala:442)
at kafka.api.ConsumerTest.testPatternSubscription(ConsumerTest.scala:95)
Caused by:
org.apache.kafka.common.errors.NetworkException: The server
disconnected before a response was received.
kafka.integration.RollingBounceTest > testRollingBounce PASSED
kafka.server.ServerGenerateBrokerIdTest > testAutoGenerateBrokerId PASSED
kafka.server.ServerGenerateBrokerIdTest > testMultipleLogDirsMetaProps PASSED
kafka.server.ServerGenerateBrokerIdTest > testUserConfigAndGeneratedBrokerId
PASSED
kafka.server.ServerGenerateBrokerIdTest >
testConsistentBrokerIdFromUserConfigAndMetaProps PASSED
kafka.coordinator.CoordinatorMetadataTest >
testBindGroupToTopicsAlreadyListenedOn PASSED
kafka.coordinator.CoordinatorMetadataTest > testGetGroup PASSED
kafka.coordinator.CoordinatorMetadataTest > testBindNonexistentGroupToTopics
PASSED
kafka.coordinator.CoordinatorMetadataTest > testBindGroupToTopicsNotListenedOn
PASSED
kafka.coordinator.CoordinatorMetadataTest >
testUnbindNonexistentGroupFromTopics PASSED
kafka.coordinator.CoordinatorMetadataTest >
testAddGroupReturnsPreexistingGroupIfItAlreadyExists PASSED
kafka.coordinator.CoordinatorMetadataTest >
testUnbindGroupFromTopicsListenedOnByNoOtherGroup PASSED
kafka.coordinator.CoordinatorMetadataTest > testRemoveNonexistentGroup PASSED
kafka.coordinator.CoordinatorMetadataTest >
testUnbindGroupFromTopicsNotListenedOn PASSED
kafka.coordinator.CoordinatorMetadataTest >
testUnbindGroupFromTopicsListenedOnByOtherGroups PASSED
kafka.coordinator.CoordinatorMetadataTest >
testRemoveGroupWithNoOtherGroupsBoundToItsTopics PASSED
kafka.coordinator.CoordinatorMetadataTest >
testRemoveGroupWithOtherGroupsBoundToItsTopics PASSED
kafka.coordinator.CoordinatorMetadataTest > testGetNonexistentGroup PASSED
kafka.metrics.KafkaTimerTest > testKafkaTimer PASSED
kafka.admin.AddPartitionsTest > testWrongReplicaCount PASSED
kafka.admin.AddPartitionsTest > testTopicDoesNotExist PASSED
kafka.admin.AddPartitionsTest > testIncrementPartitions PASSED
kafka.admin.AddPartitionsTest > testManualAssignmentOfReplicas PASSED
kafka.admin.AddPartitionsTest > testReplicaPlacement PASSED
kafka.api.ProducerBounceTest > testBrokerFailure FAILED
java.lang.AssertionError
at org.junit.Assert.fail(Assert.java:86)
at org.junit.Assert.assertTrue(Assert.java:41)
at org.junit.Assert.assertTrue(Assert.java:52)
at
kafka.api.ProducerBounceTest.testBrokerFailure(ProducerBounceTest.scala:117)
kafka.producer.SyncProducerTest > testReachableServer PASSED
kafka.producer.SyncProducerTest > testMessageSizeTooLarge PASSED
kafka.producer.SyncProducerTest > testNotEnoughReplicas PASSED
kafka.producer.SyncProducerTest > testMessageSizeTooLargeWithAckZero PASSED
kafka.producer.SyncProducerTest > testProducerCanTimeout PASSED
kafka.producer.SyncProducerTest > testProduceRequestWithNoResponse PASSED
kafka.producer.SyncProducerTest > testEmptyProduceRequest PASSED
kafka.producer.SyncProducerTest > testProduceCorrectlyReceivesResponse PASSED
kafka.consumer.PartitionAssignorTest > testRoundRobinPartitionAssignor PASSED
kafka.consumer.PartitionAssignorTest > testRangePartitionAssignor PASSED
kafka.server.PlaintextReplicaFetchTest > testReplicaFetcherThread PASSED
kafka.utils.ReplicationUtilsTest > testUpdateLeaderAndIsr PASSED
kafka.utils.ReplicationUtilsTest > testGetLeaderIsrAndEpochForPartition PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[0] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[1] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[2] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[3] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[4] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[5] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[6] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[7] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[8] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[9] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[10] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[11] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[12] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[13] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[14] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[15] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[16] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[17] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[18] PASSED
kafka.log.BrokerCompressionTest > testBrokerSideCompression[19] PASSED
528 tests completed, 11 failed
:core:test FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':core:test'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/Kafka-trunk/ws/core/build/reports/tests/index.html>
* 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: 31 mins 6.846 secs
Build step 'Execute shell' marked build as failure
Setting
GRADLE_2_1_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_2.1
