kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Jenkins Server <jenk...@builds.apache.org>
Subject Build failed in Jenkins: Kafka-trunk #150
Date Mon, 26 Nov 2012 18:51:26 GMT
See <https://builds.apache.org/job/Kafka-trunk/150/changes>

Changes:

[junrao] copy branch 0.8 to trunk

[junrao] move shutting down of fetcher thread out of critical path; patched by Jun Rao; reviewed
by Neha Narkhede; KAFKA-612

[nehanarkhede] KAFKA-532 Multiple controllers can co-exist during soft failures; patched by
Neha Narkhede; reviewed by Jun Rao

[jjkoshy] Fix deadlock between leader-finder-thread and consumer-fetcher-thread during broker
failure; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-618
pre-commit-status-crumb=5e65bf7a-f347-4600-b3ae-99eed1cd2a78

[junrao] MigrationTool should disable shallow iteration in the 0.7 consumer; patched by Yang
Ye; reviewed by Jun Rao; KAFKA-613

[junrao] DumpLogSegment offset verification is incorrect for compressed messages; patched
by Yang Ye; reviewed by Jun Rao; KAFKA-614

[jkreps] KAFKA-544 Trivial fix--migration tool is using message when it should be using a
byte array. Checked in w/o review.

[junrao] System Test - Log Retention Cases should wait longer before getting the common starting
offset in replica log segments; patched by John Fung; reviewed by Jun Rao; KAFKA-605

[junrao] trivial fix to make the default value replica.fetch.min.bytes better for replication

[jkreps] KAFKA-545 Add some log performance tests.

[jkreps] KAFKA-544 Store the key given to the producer in the message. Expose this key in
the consumer. Patch reviewed by Jun.

[nehanarkhede] KAFKA-574 KafkaController unnecessarily reads leaderAndIsr info from ZK ; patched
by Prashanth; reviewed by Jun and Neha

[jjkoshy] Remove custom metrics jar and replace with latest from metrics HEAD; patched by
Joel Koshy; reviewed by Jun Rao; KAFKA-585.

[junrao] Add test cases to test log size retention and more; patched by John Fung; reviewed
by Jun Rao; KAFKA-591

[junrao] Fix commit() in zk consumer for compressed messages; patched by Swapnil Ghike; reviewed
by Jun Rao; KAFKA-546

[nehanarkhede] KAFKA-593 Empty log index file created when it shouldn't be empty; Patched
by Yang Ye; reviewed by Jun and Jay

[junrao] extend DumpLogSegments to verify consistency btw data and index; patched by Yang
Ye; reviewed by Jun Rao; KAFKA-577

[junrao] LogSegment.firstAppendTime not reset after truncate to; patched by Swapnil Ghike;
reviewed by Jun Rao, Neha Narkhede; KAFKA-596

[jkreps] KAFKA-188 Support multiple data directories. 
Patch reviewed by Neha and Jun.

[junrao] KafkaRequestHandler needs to handle exceptions; patched by Yang Ye; reviewed by Jun
Rao; KAFKA-491

[junrao] system test configs are broken; patched by John Fung; reviewed by Jun Rao; kafka-586

[junrao] Update System Test due to new argument --sync in ProducerPerformance; patched by
Jun Rao; reviewed by Neha Narkhede and Jun Rao; kafka-594

[jkreps] KAFKA-588 Fix bug in OffsetIndex.truncateTo. Reviewed by Neha.

[junrao] Register metrics beans at kafka server startup; patched by Swapnil Ghike; reviewed
by Jun Rao; KAFKA-592

[junrao] Partition.makeFollower() reads broker info from ZK; patched by Swapnil Ghike; reviewed
by Jun Rao; KAFKA-575

[junrao] extend DumpLogSegments to verify consistency btw data and index; patched by Yang
Ye; reviewed by Neha Narkhede and Jun Rao; KAFKA-577

[junrao] trivial fix to use foreach instead of map

[jjkoshy] Implement clean shutdown in replication; patched by Joel Koshy; reviewed by Jun
Rao and Neha Narkhede; KAFKA-340

[junrao] produce/fetch remote time metric not set correctly when num.acks = 1; patched by
Jun Rao; reviewed by Neha Narkhede; KAFKA-584

[junrao] trivial fix to add the missing Logging class

[junrao] Add more test cases to System Test ; patched by John Fung; reviewed by Jun Rao; KAFKA-571

[junrao] provides windows batch script for starting Kafka/Zookeeper; patched by Antoine Vianey;
reviewed by Jun Rao; kafka-581

[junrao] remove connection timeout in SyncProducer; patched by Swapnil Ghike; reviewed by
Jun Rao; kafka-579

[junrao] Change MessageSet.sizeInBytes to Int; patched by Swapnil Ghike; reviewed by Jun Rao;
kafka-556

[junrao] SimpleConsumer throws UnsupportedOperationException: empty.head; patched by Yang
Ye; reviewed by Jun Rao; kafka-576

[junrao] system test testcase_0122 under replication fails due to large # of data loss; patched
by Jun Rao; reviewed by Neha Narkhede; KAFKA-580

[nehanarkhede] KAFKA-541 Move to metrics csv reporter for system tests; patched by Yang Ye;
reviewed by Neha, Jun and Joel

[junrao] System Test : Leader Failure Log Segment Checksum Mismatched When request-num-acks
is 1; patched by Jun Rao; reviewed by John Fung, Joel Koshy and Neha Narkhede; KAFKA-573

[nehanarkhede] KAFKA-537 Expose clientId in ConsumerConfig and fix correlation id; patched
by Yang Ye; reviewed by Neha Narkhede

[jkreps] KAFKA-569 Split up utils package and do some cleanup. Patch reviewed by Neha.

[nehanarkhede] KAFKA-43 Move leader to preferred replica; patched by Neha Narkhede; reviewed
by Joel Koshy and Jun Rao

[nehanarkhede] KAFKA-548 remove partition from ProducerRequestPartitionData and FetchResponsePartitionData;
patched by Yang Ye; reviewed by Neha and Joel

[junrao] Replication Data Loss in Mirror Maker Bouncing testcase; patched by Jun Rao; reviewed
by Joel Koshy, John Fung and Neha Narkhede; kafka-567

[junrao] trival fix to remove 2 empty files

[nehanarkhede] Changing kafka-server-stop.sh to use SIGTERM for Kafka server process termination.
No review

[nehanarkhede] KAFKA-432 allow consumer to read from followers; patched by Yang Ye; reviewed
by Neha and Jun

[jkreps] KAFKA-506 Hadoop consumer not advancing to next offset. No review.

[nehanarkhede] KAFKA-510 Broker needs to know replication factor per partition; patched by
Yang Ye; reviewed by Neha Narkhede, Jun Rao and Joel Koshy

[jkreps] KAFKA-557 Patch to avoid assigning offsets to Log.appends as part of replication.
Reviewed by Neha.

[jkreps] KAFKA-506 Misc. follow-up cleanups from Neha's review.

[nehanarkhede] KAFKA-42 part 2: new files

[nehanarkhede] KAFKA-42 Cluster expansion feature; patched by Neha; reviewed by Jun

[nehanarkhede] Reverting KAFKA-42 since it accidentally contained changes to metrics package.
Didn't catch it due to a stale sbt cache. It is better to redo the patch and then commit

[nehanarkhede] KAFKA-42 Cluster expansion feature; patched by Neha Narkhede; reviewed by Jun
Rao

[nehanarkhede] Reverting KAFKA-510, to be reapplied after addressing review comments and after
KAFKA-42 is checked in

[junrao] trival fix to make run_sanity.sh executable

[nehanarkhede] KAFKA-502 Adding 30 more system tests, reviewed by Jun and Neha; patched by
John Fung

[junrao] trival fix to kafka-563: KafkaScheduler shutdown in ZookeeperConsumerConnector should
check for config.autocommit

[junrao] broker needs to know the replication factor per partition; patched by Yang Ye; reviewed
by Jun Rao; kafka-510

[junrao] confusing reference to zk.connect in config/producer.properties; patched by yazgoo;
reviewed by Jun Rao; kafka-553

[jkreps] KAFKA-543 Avoid sending duplicate topic names in TopicMetadataRequest. Reviewed by
Neha.

------------------------------------------
[...truncated 1786 lines...]
[info] Test Starting: testReopenThenTruncate
[info] Test Passed: testReopenThenTruncate
[info] == core-kafka / kafka.log.LogTest ==
[info] 
[info] == core-kafka / kafka.server.ServerShutdownTest ==
[info] Test Starting: testCleanShutdown(kafka.server.ServerShutdownTest)
[info] Test Passed: testCleanShutdown(kafka.server.ServerShutdownTest)
[info] == core-kafka / kafka.server.ServerShutdownTest ==
[info] 
[info] == core-kafka / kafka.server.SimpleFetchTest ==
[info] Test Starting: testNonReplicaSeesHwWhenFetching(kafka.server.SimpleFetchTest)
[info] Test Passed: testNonReplicaSeesHwWhenFetching(kafka.server.SimpleFetchTest)
[info] Test Starting: testReplicaSeesLeoWhenFetching(kafka.server.SimpleFetchTest)
[info] Test Passed: testReplicaSeesLeoWhenFetching(kafka.server.SimpleFetchTest)
[info] == core-kafka / kafka.server.SimpleFetchTest ==
[info] 
[info] == core-kafka / kafka.producer.SyncProducerTest ==
[info] Test Starting: testReachableServer(kafka.producer.SyncProducerTest)
[info] Test Passed: testReachableServer(kafka.producer.SyncProducerTest)
[info] Test Starting: testEmptyProduceRequest(kafka.producer.SyncProducerTest)
[info] Test Passed: testEmptyProduceRequest(kafka.producer.SyncProducerTest)
[info] Test Starting: testMessageSizeTooLarge(kafka.producer.SyncProducerTest)
[info] Test Passed: testMessageSizeTooLarge(kafka.producer.SyncProducerTest)
[info] Test Starting: testProduceCorrectlyReceivesResponse(kafka.producer.SyncProducerTest)
[info] Test Passed: testProduceCorrectlyReceivesResponse(kafka.producer.SyncProducerTest)
[info] Test Starting: testProducerCanTimeout(kafka.producer.SyncProducerTest)
[info] Test Passed: testProducerCanTimeout(kafka.producer.SyncProducerTest)
[info] == core-kafka / kafka.producer.SyncProducerTest ==
[info] 
[info] == core-kafka / kafka.zk.ZKEphemeralTest ==
[info] Test Starting: testEphemeralNodeCleanup(kafka.zk.ZKEphemeralTest)
[info] Test Passed: testEphemeralNodeCleanup(kafka.zk.ZKEphemeralTest)
[info] == core-kafka / kafka.zk.ZKEphemeralTest ==
[info] 
[info] == core-kafka / kafka.message.MessageCompressionTest ==
[info] Test Starting: testSimpleCompressDecompress
java.lang.reflect.InvocationTargetException
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.xerial.snappy.SnappyLoader.loadNativeLibrary(SnappyLoader.java:317)
	at org.xerial.snappy.SnappyLoader.load(SnappyLoader.java:219)
	at org.xerial.snappy.Snappy.<clinit>(Snappy.java:44)
	at org.xerial.snappy.SnappyOutputStream.<init>(SnappyOutputStream.java:79)
	at org.xerial.snappy.SnappyOutputStream.<init>(SnappyOutputStream.java:66)
	at kafka.message.MessageCompressionTest.isSnappyAvailable(MessageCompressionTest.scala:57)
	at kafka.message.MessageCompressionTest.testSimpleCompressDecompress(MessageCompressionTest.scala:31)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.internal.runners.TestMethodRunner.executeMethodBody(TestMethodRunner.java:99)
	at org.junit.internal.runners.TestMethodRunner.runUnprotected(TestMethodRunner.java:81)
	at org.junit.internal.runners.BeforeAndAfterRunner.runProtected(BeforeAndAfterRunner.java:34)
	at org.junit.internal.runners.TestMethodRunner.runMethod(TestMethodRunner.java:75)
	at org.junit.internal.runners.TestMethodRunner.run(TestMethodRunner.java:45)
	at org.junit.internal.runners.TestClassMethodsRunner.invokeTestMethod(TestClassMethodsRunner.java:71)
	at org.junit.internal.runners.TestClassMethodsRunner.run(TestClassMethodsRunner.java:35)
	at org.junit.internal.runners.TestClassRunner$1.runUnprotected(TestClassRunner.java:42)
	at org.junit.internal.runners.BeforeAndAfterRunner.runProtected(BeforeAndAfterRunner.java:34)
	at org.junit.internal.runners.TestClassRunner.run(TestClassRunner.java:52)
	at org.junit.internal.runners.CompositeRunner.run(CompositeRunner.java:29)
	at org.junit.runner.JUnitCore.run(JUnitCore.java:121)
	at org.junit.runner.JUnitCore.run(JUnitCore.java:100)
	at org.junit.runner.JUnitCore.run(JUnitCore.java:91)
	at org.scalatest.junit.JUnitSuite$class.run(JUnitSuite.scala:261)
	at kafka.message.MessageCompressionTest.run(MessageCompressionTest.scala:26)
	at org.scalatest.tools.ScalaTestFramework$ScalaTestRunner.run(ScalaTestFramework.scala:40)
	at sbt.TestRunner.run(TestFramework.scala:53)
	at sbt.TestRunner.runTest$1(TestFramework.scala:67)
	at sbt.TestRunner.run(TestFramework.scala:76)
	at sbt.TestFramework$$anonfun$10$$anonfun$apply$11.runTest$2(TestFramework.scala:194)
	at sbt.TestFramework$$anonfun$10$$anonfun$apply$11$$anonfun$apply$12.apply(TestFramework.scala:205)
	at sbt.TestFramework$$anonfun$10$$anonfun$apply$11$$anonfun$apply$12.apply(TestFramework.scala:205)
	at sbt.NamedTestTask.run(TestFramework.scala:92)
	at sbt.ScalaProject$$anonfun$sbt$ScalaProject$$toTask$1.apply(ScalaProject.scala:193)
	at sbt.ScalaProject$$anonfun$sbt$ScalaProject$$toTask$1.apply(ScalaProject.scala:193)
	at sbt.TaskManager$Task.invoke(TaskManager.scala:62)
	at sbt.impl.RunTask.doRun$1(RunTask.scala:77)
	at sbt.impl.RunTask.runTask(RunTask.scala:85)
	at sbt.impl.RunTask.sbt$impl$RunTask$$runIfNotRoot(RunTask.scala:60)
	at sbt.impl.RunTask$$anonfun$runTasksExceptRoot$2.apply(RunTask.scala:48)
	at sbt.impl.RunTask$$anonfun$runTasksExceptRoot$2.apply(RunTask.scala:48)
	at sbt.Distributor$Run$Worker$$anonfun$2.apply(ParallelRunner.scala:131)
	at sbt.Distributor$Run$Worker$$anonfun$2.apply(ParallelRunner.scala:131)
	at sbt.Control$.trapUnit(Control.scala:19)
	at sbt.Distributor$Run$Worker.run(ParallelRunner.scala:131)
Caused by: java.lang.UnsatisfiedLinkError: no snappyjava in java.library.path
	at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1734)
	at java.lang.Runtime.loadLibrary0(Runtime.java:823)
	at java.lang.System.loadLibrary(System.java:1028)
	at org.xerial.snappy.SnappyNativeLoader.loadLibrary(SnappyNativeLoader.java:52)
	... 51 more
[info] Test Passed: testSimpleCompressDecompress
[info] Test Starting: testComplexCompressDecompress
[info] Test Passed: testComplexCompressDecompress
[info] == core-kafka / kafka.message.MessageCompressionTest ==
[info] 
[info] == core-kafka / kafka.server.ReplicaFetchTest ==
[info] Test Starting: testReplicaFetcherThread(kafka.server.ReplicaFetchTest)
[info] Test Passed: testReplicaFetcherThread(kafka.server.ReplicaFetchTest)
[info] == core-kafka / kafka.server.ReplicaFetchTest ==
[info] 
[info] == core-kafka / kafka.log.FileMessageSetTest ==
[info] Test Starting: testWrittenEqualsRead
[info] Test Passed: testWrittenEqualsRead
[info] Test Starting: testIteratorIsConsistent
[info] Test Passed: testIteratorIsConsistent
[info] Test Starting: testSizeInBytes
[info] Test Passed: testSizeInBytes
[info] Test Starting: testWriteTo
[info] Test Passed: testWriteTo
[info] Test Starting: testFileSize
[info] Test Passed: testFileSize
[info] Test Starting: testIterationOverPartialAndTruncation
[info] Test Passed: testIterationOverPartialAndTruncation
[info] Test Starting: testIterationDoesntChangePosition
[info] Test Passed: testIterationDoesntChangePosition
[info] Test Starting: testRead
[info] Test Passed: testRead
[info] Test Starting: testSearch
[info] Test Passed: testSearch
[info] == core-kafka / kafka.log.FileMessageSetTest ==
[info] 
[info] == core-kafka / kafka.integration.FetcherTest ==
[info] Test Starting: testFetcher(kafka.integration.FetcherTest)
[info] Test Passed: testFetcher(kafka.integration.FetcherTest)
[info] == core-kafka / kafka.integration.FetcherTest ==
[info] 
[info] == core-kafka / kafka.consumer.TopicFilterTest ==
[info] Test Starting: testWhitelists
[info] Test Passed: testWhitelists
[info] Test Starting: testBlacklists
[info] Test Passed: testBlacklists
[info] == core-kafka / kafka.consumer.TopicFilterTest ==
[info] 
[info] == core-kafka / kafka.server.IsrExpirationTest ==
[info] Test Starting: testIsrExpirationForStuckFollowers(kafka.server.IsrExpirationTest)
[info] Test Passed: testIsrExpirationForStuckFollowers(kafka.server.IsrExpirationTest)
[info] Test Starting: testIsrExpirationForSlowFollowers(kafka.server.IsrExpirationTest)
[info] Test Passed: testIsrExpirationForSlowFollowers(kafka.server.IsrExpirationTest)
[info] == core-kafka / kafka.server.IsrExpirationTest ==
[info] 
[info] == core-kafka / kafka.producer.ProducerTest ==
[info] Test Starting: testUpdateBrokerPartitionInfo(kafka.producer.ProducerTest)
[info] Test Passed: testUpdateBrokerPartitionInfo(kafka.producer.ProducerTest)
[info] Test Starting: testSendToNewTopic(kafka.producer.ProducerTest)
[info] Test Passed: testSendToNewTopic(kafka.producer.ProducerTest)
[info] Test Starting: testSendWithDeadBroker(kafka.producer.ProducerTest)
[info] Test Passed: testSendWithDeadBroker(kafka.producer.ProducerTest)
[info] Test Starting: testAsyncSendCanCorrectlyFailWithTimeout(kafka.producer.ProducerTest)
[info] Test Passed: testAsyncSendCanCorrectlyFailWithTimeout(kafka.producer.ProducerTest)
[info] == core-kafka / kafka.producer.ProducerTest ==
[info] 
[info] == core-kafka / kafka.server.RequestPurgatoryTest ==
[info] Test Starting: testRequestSatisfaction(kafka.server.RequestPurgatoryTest)
[info] Test Passed: testRequestSatisfaction(kafka.server.RequestPurgatoryTest)
[info] Test Starting: testRequestExpiry(kafka.server.RequestPurgatoryTest)
[info] Test Passed: testRequestExpiry(kafka.server.RequestPurgatoryTest)
[info] == core-kafka / kafka.server.RequestPurgatoryTest ==
[info] 
[info] == core-kafka / kafka.integration.TopicMetadataTest ==
[info] Test Starting: testTopicMetadataRequest(kafka.integration.TopicMetadataTest)
[info] Test Passed: testTopicMetadataRequest(kafka.integration.TopicMetadataTest)
[info] Test Starting: testBasicTopicMetadata(kafka.integration.TopicMetadataTest)
[info] Test Passed: testBasicTopicMetadata(kafka.integration.TopicMetadataTest)
[info] Test Starting: testAutoCreateTopic(kafka.integration.TopicMetadataTest)
[info] Test Passed: testAutoCreateTopic(kafka.integration.TopicMetadataTest)
[info] == core-kafka / kafka.integration.TopicMetadataTest ==
[info] 
[info] == core-kafka / kafka.network.SocketServerTest ==
[info] Test Starting: simpleRequest
[info] Test Passed: simpleRequest
[info] Test Starting: tooBigRequestIsRejected
[info] Test Passed: tooBigRequestIsRejected
[info] == core-kafka / kafka.network.SocketServerTest ==
[info] 
[info] == core-kafka / kafka.api.RequestResponseSerializationTest ==
[info] Test Starting: testSerializationAndDeserialization
[info] Test Passed: testSerializationAndDeserialization
[info] == core-kafka / kafka.api.RequestResponseSerializationTest ==
[info] 
[info] == core-kafka / kafka.message.ByteBufferMessageSetTest ==
[info] Test Starting: testWrittenEqualsRead
[info] Test Passed: testWrittenEqualsRead
[info] Test Starting: testIteratorIsConsistent
[info] Test Passed: testIteratorIsConsistent
[info] Test Starting: testSizeInBytes
[info] Test Passed: testSizeInBytes
[info] Test Starting: testEquals
[info] Test Passed: testEquals
[info] Test Starting: testWriteTo
[info] Test Passed: testWriteTo
[info] Test Starting: testValidBytes
[info] Test Passed: testValidBytes
[info] Test Starting: testValidBytesWithCompression
[info] Test Passed: testValidBytesWithCompression
[info] Test Starting: testIterator
[info] Test Passed: testIterator
[info] Test Starting: testOffsetAssignment
[info] Test Passed: testOffsetAssignment
[info] == core-kafka / kafka.message.ByteBufferMessageSetTest ==
[info] 
[info] == core-kafka / test-finish ==
[error] Failed: : Total 167, Failed 2, Errors 0, Passed 165, Skipped 0
[info] == core-kafka / test-finish ==
[info] 
[info] == core-kafka / Test cleanup 1 ==
[info] Deleting directory /var/tmp/sbt_323dbff1
[info] == core-kafka / Test cleanup 1 ==
[info] 
[info] == core-kafka / test-cleanup ==
[info] == core-kafka / test-cleanup ==
[info] 
[info] == perf / test-compile ==
[info]   Source analysis: 0 new/modified, 0 indirectly invalidated, 0 removed.
[info] Compiling test sources...
[info] Nothing to compile.
[info]   Post-analysis: 0 classes.
[info] == perf / test-compile ==
[info] 
[info] == hadoop consumer / test-compile ==
[info]   Source analysis: 0 new/modified, 0 indirectly invalidated, 0 removed.
[info] Compiling test sources...
[info] Nothing to compile.
[info]   Post-analysis: 0 classes.
[info] == hadoop consumer / test-compile ==
[info] 
[info] == hadoop producer / copy-test-resources ==
[info] == hadoop producer / copy-test-resources ==
[info] 
[info] == hadoop producer / copy-resources ==
[info] == hadoop producer / copy-resources ==
[info] 
[info] == java-examples / copy-resources ==
[info] == java-examples / copy-resources ==
[info] 
[info] == perf / copy-test-resources ==
[info] == perf / copy-test-resources ==
[error] Error running kafka.admin.AdminTest: Test FAILED
[error] Error running kafka.log.LogTest: Test FAILED
[error] Error running test: One or more subtasks failed
[info] 
[info] Total time: 316 s, completed Nov 26, 2012 6:52:21 PM
[info] 
[info] Total session time: 320 s, completed Nov 26, 2012 6:52:21 PM
[error] Error during build.
Build step 'Execute shell' marked build as failure

Mime
View raw message