See <https://builds.apache.org/job/Kafka-trunk/184/changes>
Changes: [neha.narkhede] KAFKA-1432 followup - Fixing the shutdown sequence furthermore; reviewed by Neha Narkhede [junrao] kafka-1432; followup patch to enable new producer in system test; patched by Guozhang Wang; reviewed by Neha Narkhede, Jun Rao ------------------------------------------ [...truncated 581 lines...] :perf:compileScala :perf:processResources UP-TO-DATE :perf:classes :perf:compileTestJava UP-TO-DATE :perf:compileTestScala UP-TO-DATE :perf:processTestResources UP-TO-DATE :perf:testClasses UP-TO-DATE :perf:test :contrib:hadoop-consumer:compileJavaNote: Some input files use or override a deprecated API. Note: Recompile with -Xlint:deprecation for details. Note: <https://builds.apache.org/job/Kafka-trunk/ws/contrib/hadoop-consumer/src/main/java/kafka/etl/impl/DataGenerator.java> uses unchecked or unsafe operations. Note: Recompile with -Xlint:unchecked for details. :contrib:hadoop-consumer:processResources UP-TO-DATE :contrib:hadoop-consumer:classes :contrib:hadoop-consumer:compileTestJava UP-TO-DATE :contrib:hadoop-consumer:processTestResources UP-TO-DATE :contrib:hadoop-consumer:testClasses UP-TO-DATE :contrib:hadoop-consumer:test :contrib:hadoop-producer:compileJava :contrib:hadoop-producer:processResources UP-TO-DATE :contrib:hadoop-producer:classes :contrib:hadoop-producer:compileTestJava UP-TO-DATE :contrib:hadoop-producer:processTestResources UP-TO-DATE :contrib:hadoop-producer:testClasses UP-TO-DATE :contrib:hadoop-producer:test BUILD SUCCESSFUL Total time: 5 mins 56.861 secs [Kafka-trunk] $ /bin/bash -xe /tmp/hudson9098167881436304610.sh + ./gradlew -PscalaVersion=2.8.0 test The TaskContainer.add() method has been deprecated and is scheduled to be removed in Gradle 2.0. Please use the create() method instead. Building project 'core' with Scala version 2.8.0 Building project 'perf' with Scala version 2.8.0 :clients:compileJava UP-TO-DATE :clients:processResources UP-TO-DATE :clients:classes UP-TO-DATE :clients:compileTestJava UP-TO-DATE :clients:processTestResources UP-TO-DATE :clients:testClasses UP-TO-DATE :clients:test UP-TO-DATE :contrib:compileJava UP-TO-DATE :contrib:processResources UP-TO-DATE :contrib:classes UP-TO-DATE :contrib:compileTestJava UP-TO-DATE :contrib:processTestResources UP-TO-DATE :contrib:testClasses UP-TO-DATE :contrib:test UP-TO-DATE :clients:jar UP-TO-DATE :core:compileJava UP-TO-DATE :core:compileScala <https://builds.apache.org/job/Kafka-trunk/ws/core/src/main/scala/kafka/admin/AdminUtils.scala>:253: non variable type-argument String in type pattern scala.collection.Map[String,_] is unchecked since it is eliminated by erasure case Some(map: Map[String, _]) => ^ <https://builds.apache.org/job/Kafka-trunk/ws/core/src/main/scala/kafka/admin/AdminUtils.scala>:256: non variable type-argument String in type pattern scala.collection.Map[String,String] is unchecked since it is eliminated by erasure case Some(config: Map[String, String]) => ^ <https://builds.apache.org/job/Kafka-trunk/ws/core/src/main/scala/kafka/api/LeaderAndIsrResponse.scala>:66: non variable type-argument String in type pattern (String, Int) is unchecked since it is eliminated by erasure for ((key:(String, Int), value) <- responseMap) { ^ <https://builds.apache.org/job/Kafka-trunk/ws/core/src/main/scala/kafka/utils/Utils.scala>:368: non variable type-argument V in type pattern List[V] is unchecked since it is eliminated by erasure case Some(l: List[V]) => m.put(k, v :: l) ^ four warnings found :core:processResources UP-TO-DATE :core:classes :core:compileTestJava UP-TO-DATE :core:compileTestScala :core:processTestResources UP-TO-DATE :core:testClasses :core:test unit.kafka.common.ConfigTest > testInvalidClientIds PASSED unit.kafka.common.ConfigTest > testInvalidGroupIds PASSED unit.kafka.common.TopicTest > testInvalidTopicNames PASSED kafka.message.MessageTest > testFieldValues PASSED kafka.message.MessageTest > testChecksum PASSED kafka.message.MessageTest > testEquality PASSED kafka.message.MessageTest > testIsHashable PASSED kafka.message.MessageCompressionTest > testSimpleCompressDecompress PASSED kafka.message.MessageCompressionTest > testComplexCompressDecompress PASSED kafka.message.ByteBufferMessageSetTest > testWrittenEqualsRead PASSED kafka.message.ByteBufferMessageSetTest > testIteratorIsConsistent PASSED kafka.message.ByteBufferMessageSetTest > testSizeInBytes PASSED kafka.message.ByteBufferMessageSetTest > testWriteTo PASSED kafka.message.ByteBufferMessageSetTest > testValidBytes PASSED kafka.message.ByteBufferMessageSetTest > testValidBytesWithCompression PASSED kafka.message.ByteBufferMessageSetTest > testEquals PASSED kafka.message.ByteBufferMessageSetTest > testIterator PASSED kafka.message.ByteBufferMessageSetTest > testOffsetAssignment PASSED kafka.zk.ZKEphemeralTest > testEphemeralNodeCleanup PASSED kafka.consumer.ZookeeperConsumerConnectorTest > testBasic PASSED kafka.consumer.ZookeeperConsumerConnectorTest > testCompression PASSED kafka.consumer.ZookeeperConsumerConnectorTest > testCompressionSetConsumption PASSED kafka.consumer.ZookeeperConsumerConnectorTest > testConsumerDecoder PASSED kafka.consumer.ZookeeperConsumerConnectorTest > testLeaderSelectionForPartition PASSED kafka.consumer.TopicFilterTest > testWhitelists PASSED kafka.consumer.TopicFilterTest > testBlacklists PASSED kafka.consumer.ConsumerIteratorTest > testConsumerIteratorDeduplicationDeepIterator PASSED kafka.consumer.ConsumerIteratorTest > testConsumerIteratorDecodingFailure PASSED kafka.log4j.KafkaLog4jAppenderTest > testKafkaLog4jConfigs PASSED kafka.log4j.KafkaLog4jAppenderTest > testLog4jAppends PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testWrittenEqualsRead PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testIteratorIsConsistent PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testSizeInBytes PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testEquals PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testIteratorIsConsistentWithCompression PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testSizeInBytesWithCompression PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testEqualsWithCompression PASSED kafka.javaapi.consumer.ZookeeperConsumerConnectorTest > testBasic PASSED kafka.producer.AsyncProducerTest > testProducerQueueSize PASSED kafka.producer.AsyncProducerTest > testProduceAfterClosed PASSED kafka.producer.AsyncProducerTest > testBatchSize PASSED kafka.producer.AsyncProducerTest > testQueueTimeExpired PASSED kafka.producer.AsyncProducerTest > testPartitionAndCollateEvents PASSED kafka.producer.AsyncProducerTest > testSerializeEvents PASSED kafka.producer.AsyncProducerTest > testInvalidPartition PASSED kafka.producer.AsyncProducerTest > testNoBroker PASSED kafka.producer.AsyncProducerTest > testIncompatibleEncoder PASSED kafka.producer.AsyncProducerTest > testRandomPartitioner PASSED kafka.producer.AsyncProducerTest > testFailedSendRetryLogic PASSED kafka.producer.AsyncProducerTest > testJavaProducer PASSED kafka.producer.AsyncProducerTest > testInvalidConfiguration PASSED kafka.producer.SyncProducerTest > testReachableServer PASSED kafka.producer.SyncProducerTest > testEmptyProduceRequest PASSED kafka.producer.SyncProducerTest > testMessageSizeTooLarge PASSED kafka.producer.SyncProducerTest > testMessageSizeTooLargeWithAckZero PASSED kafka.producer.SyncProducerTest > testProduceCorrectlyReceivesResponse PASSED kafka.producer.SyncProducerTest > testProducerCanTimeout PASSED kafka.producer.SyncProducerTest > testProduceRequestWithNoResponse PASSED kafka.producer.ProducerTest > testUpdateBrokerPartitionInfo PASSED kafka.producer.ProducerTest > testSendToNewTopic PASSED kafka.producer.ProducerTest > testSendWithDeadBroker PASSED kafka.producer.ProducerTest > testAsyncSendCanCorrectlyFailWithTimeout PASSED kafka.producer.ProducerTest > testSendNullMessage PASSED kafka.admin.DeleteTopicTest > testDeleteTopicWithAllAliveReplicas PASSED kafka.admin.DeleteTopicTest > testResumeDeleteTopicWithRecoveredFollower PASSED kafka.admin.DeleteTopicTest > testResumeDeleteTopicOnControllerFailover PASSED kafka.admin.DeleteTopicTest > testRequestHandlingDuringDeleteTopic PASSED kafka.admin.DeleteTopicTest > testPartitionReassignmentDuringDeleteTopic PASSED kafka.admin.DeleteTopicTest > testDeleteTopicDuringAddPartition FAILED junit.framework.AssertionFailedError: Admin path /admin/delete_topic/test path not deleted even after a replica is restarted at junit.framework.Assert.fail(Assert.java:47) at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:578) at kafka.admin.DeleteTopicTest.verifyTopicDeletion(DeleteTopicTest.scala:333) at kafka.admin.DeleteTopicTest.testDeleteTopicDuringAddPartition(DeleteTopicTest.scala:216) kafka.admin.DeleteTopicTest > testAddPartitionDuringDeleteTopic PASSED kafka.admin.DeleteTopicTest > testRecreateTopicAfterDeletion PASSED kafka.admin.DeleteTopicTest > testAutoCreateAfterDeleteTopic PASSED kafka.admin.DeleteTopicTest > testDeleteNonExistingTopic PASSED kafka.admin.AdminTest > testReplicaAssignment PASSED kafka.admin.AdminTest > testManualReplicaAssignment PASSED kafka.admin.AdminTest > testTopicCreationInZK PASSED kafka.admin.AdminTest > testPartitionReassignmentWithLeaderInNewReplicas PASSED kafka.admin.AdminTest > testPartitionReassignmentWithLeaderNotInNewReplicas PASSED kafka.admin.AdminTest > testPartitionReassignmentNonOverlappingReplicas PASSED kafka.admin.AdminTest > testReassigningNonExistingPartition PASSED kafka.admin.AdminTest > testResumePartitionReassignmentThatWasCompleted PASSED kafka.admin.AdminTest > testPreferredReplicaJsonData PASSED kafka.admin.AdminTest > testBasicPreferredReplicaElection PASSED kafka.admin.AdminTest > testShutdownBroker PASSED kafka.admin.AdminTest > testTopicConfigChange PASSED Build timed out (after 60 minutes). Marking the build as failed. Build was aborted