See <https://builds.apache.org/job/Kafka-trunk/237/changes>
Changes: [junrao] kafka-1451; Broker stuck due to leader election race; patched by Manikumar Reddy; reviewed by Jun Rao ------------------------------------------ [...truncated 780 lines...] kafka.server.KafkaConfigTest > testLogRollTimeNoConfigProvided PASSED kafka.server.SimpleFetchTest > testNonReplicaSeesHwWhenFetching PASSED kafka.server.SimpleFetchTest > testReplicaSeesLeoWhenFetching PASSED kafka.server.ServerShutdownTest > testCleanShutdown PASSED kafka.server.ServerShutdownTest > testCleanShutdownWithDeleteTopicEnabled PASSED kafka.server.HighwatermarkPersistenceTest > testHighWatermarkPersistenceSinglePartition PASSED kafka.server.HighwatermarkPersistenceTest > testHighWatermarkPersistenceMultiplePartitions 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.ConsumerIteratorTest > testConsumerIteratorDeduplicationDeepIterator PASSED kafka.consumer.ConsumerIteratorTest > testConsumerIteratorDecodingFailure PASSED kafka.consumer.TopicFilterTest > testWhitelists PASSED kafka.consumer.TopicFilterTest > testBlacklists PASSED kafka.consumer.TopicFilterTest > testWildcardTopicCountGetTopicCountMapEscapeJson PASSED kafka.log.LogTest > testTimeBasedLogRoll PASSED kafka.log.LogTest > testSizeBasedLogRoll PASSED kafka.log.LogTest > testLoadEmptyLog PASSED kafka.log.LogTest > testAppendAndReadWithSequentialOffsets PASSED kafka.log.LogTest > testAppendAndReadWithNonSequentialOffsets PASSED kafka.log.LogTest > testReadAtLogGap PASSED kafka.log.LogTest > testReadOutOfRange PASSED kafka.log.LogTest > testLogRolls PASSED kafka.log.LogTest > testCompressedMessages PASSED kafka.log.LogTest > testThatGarbageCollectingSegmentsDoesntChangeOffset PASSED kafka.log.LogTest > testMessageSizeCheck PASSED kafka.log.LogTest > testLogRecoversToCorrectOffset PASSED kafka.log.LogTest > testIndexRebuild PASSED kafka.log.LogTest > testTruncateTo PASSED kafka.log.LogTest > testIndexResizingAtTruncation PASSED kafka.log.LogTest > testBogusIndexSegmentsAreRemoved PASSED kafka.log.LogTest > testReopenThenTruncate PASSED kafka.log.LogTest > testAsyncDelete PASSED kafka.log.LogTest > testOpenDeletesObsoleteFiles PASSED kafka.log.LogTest > testAppendMessageWithNullPayload PASSED kafka.log.LogTest > testCorruptLog PASSED kafka.log.LogTest > testCleanShutdownFile PASSED kafka.log.OffsetIndexTest > truncate PASSED kafka.log.OffsetIndexTest > randomLookupTest PASSED kafka.log.OffsetIndexTest > lookupExtremeCases PASSED kafka.log.OffsetIndexTest > appendTooMany PASSED kafka.log.OffsetIndexTest > appendOutOfOrder PASSED kafka.log.OffsetIndexTest > testReopen PASSED kafka.log.LogManagerTest > testCreateLog PASSED kafka.log.LogManagerTest > testGetNonExistentLog PASSED kafka.log.LogManagerTest > testCleanupExpiredSegments PASSED kafka.log.LogManagerTest > testCleanupSegmentsToMaintainSize PASSED kafka.log.LogManagerTest > testTimeBasedFlush PASSED kafka.log.LogManagerTest > testLeastLoadedAssignment PASSED kafka.log.LogManagerTest > testTwoLogManagersUsingSameDirFails PASSED kafka.log.LogManagerTest > testCheckpointRecoveryPoints PASSED kafka.log.LogManagerTest > testRecoveryDirectoryMappingWithTrailingSlash PASSED kafka.log.LogManagerTest > testRecoveryDirectoryMappingWithRelativeDirectory PASSED kafka.log.CleanerTest > testCleanSegments PASSED kafka.log.CleanerTest > testCleaningWithDeletes PASSED kafka.log.CleanerTest > testCleanSegmentsWithAbort PASSED kafka.log.CleanerTest > testSegmentGrouping PASSED kafka.log.CleanerTest > testBuildOffsetMap PASSED kafka.log.OffsetMapTest > testBasicValidation PASSED kafka.log.OffsetMapTest > testClear PASSED kafka.log.FileMessageSetTest > testWrittenEqualsRead PASSED kafka.log.FileMessageSetTest > testIteratorIsConsistent PASSED kafka.log.FileMessageSetTest > testSizeInBytes PASSED kafka.log.FileMessageSetTest > testWriteTo PASSED kafka.log.FileMessageSetTest > testFileSize PASSED kafka.log.FileMessageSetTest > testIterationOverPartialAndTruncation PASSED kafka.log.FileMessageSetTest > testIterationDoesntChangePosition PASSED kafka.log.FileMessageSetTest > testRead PASSED kafka.log.FileMessageSetTest > testSearch PASSED kafka.log.FileMessageSetTest > testIteratorWithLimits PASSED kafka.log.FileMessageSetTest > testTruncate PASSED kafka.log.LogCleanerIntegrationTest > cleanerTest PASSED kafka.log.LogSegmentTest > testTruncate PASSED kafka.log.LogSegmentTest > testReadOnEmptySegment PASSED kafka.log.LogSegmentTest > testReadBeforeFirstOffset PASSED kafka.log.LogSegmentTest > testMaxOffset PASSED kafka.log.LogSegmentTest > testReadAfterLast PASSED kafka.log.LogSegmentTest > testReadFromGap PASSED kafka.log.LogSegmentTest > testTruncateFull PASSED kafka.log.LogSegmentTest > testNextOffsetCalculation PASSED kafka.log.LogSegmentTest > testChangeFileSuffixes PASSED kafka.log.LogSegmentTest > testRecoveryFixesCorruptIndex PASSED kafka.log.LogSegmentTest > testRecoveryWithCorruptMessage 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.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.ProducerTest > testUpdateBrokerPartitionInfo PASSED kafka.producer.ProducerTest > testSendToNewTopic PASSED kafka.producer.ProducerTest > testSendWithDeadBroker PASSED kafka.producer.ProducerTest > testAsyncSendCanCorrectlyFailWithTimeout PASSED kafka.producer.ProducerTest > testSendNullMessage PASSED kafka.log4j.KafkaLog4jAppenderTest > testKafkaLog4jConfigs PASSED kafka.log4j.KafkaLog4jAppenderTest > testLog4jAppends 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 FAILED junit.framework.AssertionFailedError: Timing out after 5000 ms since leader is not elected or changed for partition [test,1] at junit.framework.Assert.fail(Assert.java:47) at kafka.utils.TestUtils$.waitUntilLeaderIsElectedOrChanged(TestUtils.scala:550) at kafka.admin.AdminTest.testBasicPreferredReplicaElection(AdminTest.scala:310) Build timed out (after 60 minutes). Marking the build as failed. Build was aborted