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-0.7 #3
Date Mon, 26 Nov 2012 18:43:54 GMT
See <https://builds.apache.org/job/Kafka-0.7/3/changes>

Changes:

[junrao] move trunk to branch 0.7

[jjkoshy] Fix wildcard consumption to work with greater than one stream; KAFKA-550; patched
by Joel Koshy; reviewed by Jun Rao and Neha Narkhede.

[junrao] The ConsumerStats MBean name should include the groupid; patched by Michael Tamm;
reviewed by Jun Rao; kafka-547

[jjkoshy] ConsumerOffsetChecker now works with hostnames (in addition to IP) in the brokers/ids
zk path; KAFKA-549; patched by Bob Cotton; reviewed by Joel Koshy

[joestein] KAFKA-538 missing apache license header in sbt and util.h

[joestein] KAFKA-533 changes to NOTICE and LICENSE related to KAFKA-534 removing client libraries
from repo

[joestein] KAFKA-534 remove client library directory

[junrao] TopicCount.constructTopicCount isn't thread-safe; patched by Jun Rao; reviewed by
Joel Koshy; KAFKA-379

[junrao] Handle topic names with / on Kafka server; patched by Swapnil Ghike; reviewed by
Jay Kreps and Jun Rao; kafka-495

[junrao] Message size not checked at the server (patch v3); patched by Swapnil Ghike; reviewed
by Jun Rao; KAFKA-469

[junrao] Require values in Utils.getTopic* methods to be positive; patched by Swapnil Ghike;
reviewed by Jun Rao; KAFKA-481

[junrao] Expose JMX operation to set logger level dynamically; patched by Jun Rao; reviewed
by Jay Kreps; KAFKA-429

[junrao] Time based log segment rollout; patched by Swapnil Ghike; reviewed by Jun Rao, Neha
Narkhede; KAFKA-475

[junrao] message size not checked at the server; patched by Swapnil Ghike; reviewed by Jun
Rao, Neha Narkhede; KAFKA-469

[jjkoshy] KAFKA-373 Fix trunk broker failure test to work with mirror maker; patched by John
Fung; reviewed by Joel Koshy

[joestein] KAFKA-368 use the pig core jar from maven instead of distributing it patch by Joe
Stein reviewed by Jun Rao and Neha Narkhede

[junrao] add jmx beans in broker to track # bytes in consumer; patched by Jun Rao; reviewed
by Joel Koshy; KAFKA-336

[joestein] KAFKA-365 change copyright in NOTICE to current year, reviewed by Jun Rao

[nehanarkhede] Minor fix: Turning on TCP NODELAY in the Simple Consumer. This fix has a significant
impact on single fetch request performance from a latency standpoint

[junrao] Mirroring should use multiple producers; add producer retries to DefaultEventHandler;
patched by Joel Koshy; reviewed by Jun Rao; KAFKA-332

[nehanarkhede] KAFKA-320 testZKSendWithDeadBroker fails intermittently due to ZKNodeExistsException;
patched by nehanarkhede; reviewed by junrao and prashanth menon

[junrao] Separate out Kafka mirroring into a stand-alone app; patched by Joel Koshy; reviewed
by Jun Rao and Neha Narkhede; KAFKA-249

[junrao] enable shallow iterator in ByteBufferMessageSet to allow mirroing data without decompression;
patched by Jun Rao; reviewed by Joel Koshy; KAFKA-315

[junrao] CallbackHandler.afterDequeuingExistingData is not called during event queue timeout;
patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-326

[nehanarkhede] KAFKA-309 Bug in FileMessageSet's append API can corrupt on disk log; patched
by nehanarkhede; reviewed by junrao

[nehanarkhede] KAFKA-310 Incomplete message set validation checks in Log's append API can
corrupt on disk log segment; patched by nehanarkhede; reviewed by junrao

[junrao] Dead code in the Log4j appender; patched by Jose Quinteiro; reviewed by Jun Rao;
KAFKA-303

[junrao] kafka-console-producer does not take in customized values of --batch-size or --timeout;
patched by Jun Rao; reviewed by Edward Smith; KAFKA-279

[junrao] reverting previous commit for KAFKA-296 because patch didn't apply cleanly

[junrao] Update Go Client to new version of Go; patched by AaronR; KAFKA-296

[junrao] LogManager test fails on linux; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-220

[junrao] trivial fix to include violated payload size in MessageSizeTooLargeException; patched
by Jun Rao

[junrao] broker deletes all file segments when cleaning up an empty log segment; patched by
Jun Rao; reviewed by Neha Narkhede; KAFKA-292

[joestein] Niek Sanders - KAFKA-284 fixed compilation issue for cpp client

[junrao] use propertyExists to test if both broker.list and zk.connect are present; patched
by Jun Rao; reviewed by Neha Narkhede; KAFKA-290

[junrao] Increase maximum value of log.retention.size; patched by Elben Shira; reviewed by
Jun Rao; KAFKA-285

[junrao] consumer sometimes don't release partition ownership properly in ZK during rebalance;
patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-286

[junrao] add jmx beans in broker to track # of failed requests; patched by Jun Rao; reviewed
by Neha Narkhede; KAFKA-283

[junrao] Add a shallow iterator to the ByteBufferMessageSet; patched by Yang Ye; reviewed
by Jun Rao; KAFKA-277

[junrao] A tool to UPDATE Zookeeper partition-offset with input from a file; patched by John
Fung; reviewed by Jun Rao; KAFKA-255

[junrao] A tool to GET Zookeeper partition-offset and output to files; patched by John Fung;
reviewed by Jun Rao; KAFKA-254

[junrao] make time-based reconnect starting at a random time; patched by Yang Ye; reviewed
by Jun Rao; KAFKA-268

[junrao] trivial fix for kafka-producer-perf-test.sh

[joestein] test access, fixed space

[nehanarkhede] KAFKA-274 Handle corrupted messages cleanly; patched by nehanarkhede; reviewed
by junrao

[junrao] shutdown watch executor thread properly; patched by Jun Rao; reviewed by Neha Narkhede;
KAFKA-265

[junrao] trivial fix to add trace logging in FetcherRunnable

[junrao] fix condition to use await instead of wait; patched by Jun Rao; reviewed by Neha
Narkhede; KAFKA-265

[junrao] add JMX on broker to track bytes/messages per topic; patched by Jun Rao; reviewed
by Neha Narkhede; KAFKA-272

[junrao] time-based reconnect in producer; patched by Yang Ye; reviewed by Jun Rao; KAFKA-268

[junrao] Add a queue of zookeeper notifications in the zookeeper consumer to reduce the number
of rebalancing attempts; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-265

[junrao] trivial change to reduce default fetcher queue size

[nehanarkhede] KAFKA-262 Bug in the consumer rebalancing logic causes one consumer to release
partitions that it does not own; patched by Neha Narkhede; reviewed by Jun Rao

[nehanarkhede] KAFKA-263 Enhance single host broker failure test to have 2 topics with uneven
distribution on the source brokers; patched by John Fung; reviewed by Neha Narkhede

[nehanarkhede] KAFKA-257 Hadoop producer should use software load balancer; patched by Sam
Shah; reviewed by nehanarkhede

[nehanarkhede] KAFKA 256 Bug in the consumer rebalancing logic leads to the consumer not pulling
data from some partitions; patched by nehanarkhede; reviewed by joelkoshy

[junrao] Corrupted request shuts down the broker; patched by Jun Rao; reviewed by Jay Kreps
and Neha Narkhede; KAFKA-261

[junrao] ConsumerIterator throws a IllegalStateException after a ConsumerTimeout occurs; patched
by Jun Rao; reviewed by Joel Koshy; KAFKA-241

[junrao] max.message.size and fetch.size defaults should be consistent; patched by Pierre-Yves
Ritschard; reviewed by Jun Rao; KAFKA-247

[nehanarkhede] KAFKA 244 Improve log4j appender to use kafka.producer.Producer; patched by
vtkstef; reviewed by nehanarkhede

[nehanarkhede] Minor fix in the broker failure test for clean shutdown of servers

[junrao] trivial fix to make output of ConsumerOffsetChecker sorted

[nehanarkhede] KAFKA-245 Pull zkclient jar from Maven; patched by pyritschard; reviewed by
nehanarkhede

[nehanarkhede] KAFKA 218 Upgrade to zookeeper 3.3.4; patched by pyritschard; reviewed by nehanarkhede

[nehanarkhede] KAFKA-228 Reduce duplicate messages served by the kafka consumer for uncompressed
topics; patched by nehanarkhede; reviewed by junrao

[junrao] Support configurable send / receive socket buffer size in server; patched by John
Fung; reviewed by Jun Rao; KAFKA-200

[nehanarkhede] KAFKA-227 Broker failure system test; patched by johnfung; reviewed by nehanarkhede

[junrao] Make backoff time during consumer rebalance configurable; patched by Jun Rao; reviewed
by Neha Narkhede; KAFKA-234

[junrao] avoid logging stacktrace directly; patched by Jun Rao; reviewed by Neha Narkhede;
KAFKA-231

[jkreps] KAFKA-229 Patch from Joe Stein. Log full exception stack trace instead of just message.

------------------------------------------
[...truncated 3982 lines...]
[info] == core-kafka / kafka.integration.LazyInitProducerTest ==
[info] Test Starting: testProduceAndFetch(kafka.integration.LazyInitProducerTest)
[info] Test Passed: testProduceAndFetch(kafka.integration.LazyInitProducerTest)
[info] Test Starting: testProduceAndMultiFetch(kafka.integration.LazyInitProducerTest)
[error] Test Failed: testProduceAndMultiFetch(kafka.integration.LazyInitProducerTest)
junit.framework.AssertionFailedError: Iterators have uneven length-- first has more: 2 >
0
	at junit.framework.Assert.fail(Assert.java:47)
	at junit.framework.Assert.assertTrue(Assert.java:20)
	at junit.framework.Assert.assertFalse(Assert.java:34)
	at kafka.utils.TestUtils$.checkEquals(TestUtils.scala:195)
	at kafka.integration.LazyInitProducerTest$$anonfun$testProduceAndMultiFetch$2.apply(LazyInitProducerTest.scala:107)
	at kafka.integration.LazyInitProducerTest$$anonfun$testProduceAndMultiFetch$2.apply(LazyInitProducerTest.scala:106)
	at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
	at scala.collection.immutable.List.foreach(List.scala:45)
	at kafka.integration.LazyInitProducerTest.testProduceAndMultiFetch(LazyInitProducerTest.scala:106)
	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 junit.framework.TestCase.runTest(TestCase.java:164)
	at junit.framework.TestCase.runBare(TestCase.java:130)
	at junit.framework.TestResult$1.protect(TestResult.java:110)
	at junit.framework.TestResult.runProtected(TestResult.java:128)
	at junit.framework.TestResult.run(TestResult.java:113)
	at junit.framework.TestCase.run(TestCase.java:120)
	at junit.framework.TestSuite.runTest(TestSuite.java:228)
	at junit.framework.TestSuite.run(TestSuite.java:223)
	at junit.framework.TestSuite.runTest(TestSuite.java:228)
	at junit.framework.TestSuite.run(TestSuite.java:223)
	at org.scalatest.junit.JUnit3Suite.run(JUnit3Suite.scala:309)
	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)
[info] Test Starting: testMultiProduce(kafka.integration.LazyInitProducerTest)
[error] Test Failed: testMultiProduce(kafka.integration.LazyInitProducerTest)
junit.framework.AssertionFailedError: Iterators have uneven length-- first has more: 2 >
0
	at junit.framework.Assert.fail(Assert.java:47)
	at junit.framework.Assert.assertTrue(Assert.java:20)
	at junit.framework.Assert.assertFalse(Assert.java:34)
	at kafka.utils.TestUtils$.checkEquals(TestUtils.scala:195)
	at kafka.integration.LazyInitProducerTest$$anonfun$testMultiProduce$3.apply(LazyInitProducerTest.scala:152)
	at kafka.integration.LazyInitProducerTest$$anonfun$testMultiProduce$3.apply(LazyInitProducerTest.scala:151)
	at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
	at scala.collection.immutable.List.foreach(List.scala:45)
	at kafka.integration.LazyInitProducerTest.testMultiProduce(LazyInitProducerTest.scala:151)
	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 junit.framework.TestCase.runTest(TestCase.java:164)
	at junit.framework.TestCase.runBare(TestCase.java:130)
	at junit.framework.TestResult$1.protect(TestResult.java:110)
	at junit.framework.TestResult.runProtected(TestResult.java:128)
	at junit.framework.TestResult.run(TestResult.java:113)
	at junit.framework.TestCase.run(TestCase.java:120)
	at junit.framework.TestSuite.runTest(TestSuite.java:228)
	at junit.framework.TestSuite.run(TestSuite.java:223)
	at junit.framework.TestSuite.runTest(TestSuite.java:228)
	at junit.framework.TestSuite.run(TestSuite.java:223)
	at org.scalatest.junit.JUnit3Suite.run(JUnit3Suite.scala:309)
	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)
[info] Test Starting: testMultiProduceResend(kafka.integration.LazyInitProducerTest)
[info] Test Passed: testMultiProduceResend(kafka.integration.LazyInitProducerTest)
[info] == core-kafka / kafka.integration.LazyInitProducerTest ==
[info] 
[info] == core-kafka / kafka.integration.BackwardsCompatibilityTest ==
[info] Test Starting: testProtocolVersion0(kafka.integration.BackwardsCompatibilityTest)
[info] Test Passed: testProtocolVersion0(kafka.integration.BackwardsCompatibilityTest)
[info] == core-kafka / kafka.integration.BackwardsCompatibilityTest ==
[info] 
[info] == core-kafka / kafka.log.LogTest ==
[info] Test Starting: testTimeBasedLogRoll
[info] Test Passed: testTimeBasedLogRoll
[info] Test Starting: testSizeBasedLogRoll
[info] Test Passed: testSizeBasedLogRoll
[info] Test Starting: testLoadEmptyLog
[info] Test Passed: testLoadEmptyLog
[info] Test Starting: testLoadInvalidLogsFails
[info] Test Passed: testLoadInvalidLogsFails
[info] Test Starting: testAppendAndRead
[info] Test Passed: testAppendAndRead
[info] Test Starting: testReadOutOfRange
[info] Test Passed: testReadOutOfRange
[info] Test Starting: testLogRolls
[info] Test Passed: testLogRolls
[info] Test Starting: testFindSegment
[info] Test Passed: testFindSegment
[info] Test Starting: testEdgeLogRolls
[info] Test Passed: testEdgeLogRolls
[info] Test Starting: testMessageSizeCheck
[info] Test Passed: testMessageSizeCheck
[info] == core-kafka / kafka.log.LogTest ==
[info] 
[info] == core-kafka / kafka.message.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] == core-kafka / kafka.message.FileMessageSetTest ==
[info] 
[info] == core-kafka / kafka.javaapi.producer.SyncProducerTest ==
[info] Test Starting: testReachableServer
[info] Test Passed: testReachableServer
[info] == core-kafka / kafka.javaapi.producer.SyncProducerTest ==
[info] 
[info] == core-kafka / kafka.producer.AsyncProducerTest ==
[info] Test Starting: testProducerQueueSize
Queue is full..
[info] Test Passed: testProducerQueueSize
[info] Test Starting: testAddAfterQueueClosed
[info] Test Passed: testAddAfterQueueClosed
[info] Test Starting: testBatchSize
[info] Test Passed: testBatchSize
[info] Test Starting: testQueueTimeExpired
[info] Test Passed: testQueueTimeExpired
[info] Test Starting: testSenderThreadShutdown
[info] Test Passed: testSenderThreadShutdown
[info] Test Starting: testCollateEvents
[info] Test Passed: testCollateEvents
[info] Test Starting: testCollateAndSerializeEvents
[info] Test Passed: testCollateAndSerializeEvents
[info] == core-kafka / kafka.producer.AsyncProducerTest ==
[info] 
[info] == core-kafka / unit.kafka.producer.ProducerMethodsTest ==
[info] Test Starting: producerThrowsNoBrokersException
[info] Test Passed: producerThrowsNoBrokersException
[info] == core-kafka / unit.kafka.producer.ProducerMethodsTest ==
[info] 
[info] == core-kafka / kafka.message.CompressionUtilTest ==
[info] Test Starting: testSimpleCompressDecompress
[info] Test Passed: testSimpleCompressDecompress
[info] Test Starting: testComplexCompressDecompress
[info] Test Passed: testComplexCompressDecompress
[info] Test Starting: testSnappyCompressDecompressExplicit
[info] Test Passed: testSnappyCompressDecompressExplicit
[info] == core-kafka / kafka.message.CompressionUtilTest ==
[info] 
[info] == hadoop producer / copy-test-resources ==
[info] == hadoop producer / copy-test-resources ==
[info] 
[info] == hadoop consumer / copy-resources ==
[info] == hadoop consumer / copy-resources ==
[info] 
[info] == java-examples / 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] == java-examples / test-compile ==
[info] 
[info] == java-examples / copy-test-resources ==
[info] == java-examples / copy-test-resources ==
[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-resources ==
[info] == hadoop producer / copy-resources ==
[info] 
[info] == hadoop consumer / copy-test-resources ==
[info] == hadoop consumer / copy-test-resources ==
[info] 
[info] == hadoop producer / 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 producer / test-compile ==
[info] 
[info] == perf / copy-test-resources ==
[info] == perf / copy-test-resources ==
[info] 
[info] == core-kafka / test-finish ==
[error] Failed: : Total 141, Failed 21, Errors 0, Passed 120, Skipped 0
[info] == core-kafka / test-finish ==
[info] 
[info] == core-kafka / Test cleanup 1 ==
[info] Deleting directory /tmp/sbt_b6d01a97
[info] == core-kafka / Test cleanup 1 ==
[info] 
[info] == core-kafka / test-cleanup ==
[info] == core-kafka / test-cleanup ==
[error] Error running kafka.log4j.KafkaLog4jAppenderTest: Test FAILED
[error] Error running test: One or more subtasks failed
[error] Error running kafka.producer.ProducerTest: Test FAILED
[error] Error running kafka.javaapi.integration.PrimitiveApiTest: Test FAILED
[error] Error running kafka.integration.PrimitiveApiTest: Test FAILED
[error] Error running kafka.javaapi.producer.ProducerTest: Test FAILED
[error] Error running kafka.zk.ZKLoadBalanceTest: Test FAILED
[error] Error running kafka.integration.LazyInitProducerTest: Test FAILED
[error] Error running kafka.consumer.ZookeeperConsumerConnectorTest: Test
FAILED
[info] 
[info] Total time: 242 s, completed Nov 26, 2012 6:43:52 PM
[info] 
[info] Total session time: 242 s, completed Nov 26, 2012 6:43:52 PM
[error] Error during build.
Build step 'Execute shell' marked build as failure

Mime
View raw message