See <https://builds.apache.org/job/Kafka-trunk/187/changes>
Changes:
[jjkoshy] KAFKA-1437; Consumer metadata response should include (empty)
coordinator information if the coordinator is unavailable; reviewed by Neha
Narkhede and Guozhang Wang.
[neha.narkhede] KAFKA-1431 ConsoleConsumer - Option to clean zk consumer
path;reviewed by Neha Narkhede and Jun Rao
[jay.kreps] KAFKA-1445 Send all partitions, regardless of how full, whenever we
are sending a request to a broker. Patch from Guozhang.
[neha.narkhede] KAFKA-1179 createMessageStreams() in
javaapi.ZookeeperConsumerConnector does not throw; reviewed by Neha Narkhede
[junrao] kafka-1453; Add a channel queue jmx in Mirror Maker; patched by
Guozhang Wang; reviewed by Jun Rao
[junrao] kafka-1453 (follow-up); Add a channel queue jmx in Mirror Maker;
patched by Guozhang Wang; reviewed by Jun Rao
[junrao] kafka-1453 (2nd follow-up); Add a channel queue jmx in Mirror Maker;
patched by Guozhang Wang; reviewed by Jun Rao
------------------------------------------
[...truncated 1689 lines...]
kafka.integration.PrimitiveApiTest > testMultiProduce FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at
kafka.integration.PrimitiveApiTest.kafka$integration$KafkaServerTestHarness$$super$setUp(PrimitiveApiTest.scala:39)
at
kafka.integration.KafkaServerTestHarness$class.setUp(KafkaServerTestHarness.scala:35)
at
kafka.integration.PrimitiveApiTest.kafka$integration$ProducerConsumerTestHarness$$super$setUp(PrimitiveApiTest.scala:39)
at
kafka.integration.ProducerConsumerTestHarness$class.setUp(ProducerConsumerTestHarness.scala:33)
at kafka.integration.PrimitiveApiTest.setUp(PrimitiveApiTest.scala:39)
kafka.integration.PrimitiveApiTest > testConsumerEmptyTopic FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at
kafka.integration.PrimitiveApiTest.kafka$integration$KafkaServerTestHarness$$super$setUp(PrimitiveApiTest.scala:39)
at
kafka.integration.KafkaServerTestHarness$class.setUp(KafkaServerTestHarness.scala:35)
at
kafka.integration.PrimitiveApiTest.kafka$integration$ProducerConsumerTestHarness$$super$setUp(PrimitiveApiTest.scala:39)
at
kafka.integration.ProducerConsumerTestHarness$class.setUp(ProducerConsumerTestHarness.scala:33)
at kafka.integration.PrimitiveApiTest.setUp(PrimitiveApiTest.scala:39)
kafka.integration.PrimitiveApiTest > testPipelinedProduceRequests FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at
kafka.integration.PrimitiveApiTest.kafka$integration$KafkaServerTestHarness$$super$setUp(PrimitiveApiTest.scala:39)
at
kafka.integration.KafkaServerTestHarness$class.setUp(KafkaServerTestHarness.scala:35)
at
kafka.integration.PrimitiveApiTest.kafka$integration$ProducerConsumerTestHarness$$super$setUp(PrimitiveApiTest.scala:39)
at
kafka.integration.ProducerConsumerTestHarness$class.setUp(ProducerConsumerTestHarness.scala:33)
at kafka.integration.PrimitiveApiTest.setUp(PrimitiveApiTest.scala:39)
kafka.integration.AutoOffsetResetTest > testResetToEarliestWhenOffsetTooHigh
FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at
kafka.integration.AutoOffsetResetTest.kafka$integration$KafkaServerTestHarness$$super$setUp(AutoOffsetResetTest.scala:32)
at
kafka.integration.KafkaServerTestHarness$class.setUp(KafkaServerTestHarness.scala:35)
at
kafka.integration.AutoOffsetResetTest.setUp(AutoOffsetResetTest.scala:46)
kafka.integration.AutoOffsetResetTest > testResetToEarliestWhenOffsetTooLow
FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at
kafka.integration.AutoOffsetResetTest.kafka$integration$KafkaServerTestHarness$$super$setUp(AutoOffsetResetTest.scala:32)
at
kafka.integration.KafkaServerTestHarness$class.setUp(KafkaServerTestHarness.scala:35)
at
kafka.integration.AutoOffsetResetTest.setUp(AutoOffsetResetTest.scala:46)
kafka.integration.AutoOffsetResetTest > testResetToLatestWhenOffsetTooHigh
FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at
kafka.integration.AutoOffsetResetTest.kafka$integration$KafkaServerTestHarness$$super$setUp(AutoOffsetResetTest.scala:32)
at
kafka.integration.KafkaServerTestHarness$class.setUp(KafkaServerTestHarness.scala:35)
at
kafka.integration.AutoOffsetResetTest.setUp(AutoOffsetResetTest.scala:46)
kafka.integration.AutoOffsetResetTest > testResetToLatestWhenOffsetTooLow FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at
kafka.integration.AutoOffsetResetTest.kafka$integration$KafkaServerTestHarness$$super$setUp(AutoOffsetResetTest.scala:32)
at
kafka.integration.KafkaServerTestHarness$class.setUp(KafkaServerTestHarness.scala:35)
at
kafka.integration.AutoOffsetResetTest.setUp(AutoOffsetResetTest.scala:46)
kafka.integration.TopicMetadataTest > testAutoCreateTopic FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at kafka.integration.TopicMetadataTest.setUp(TopicMetadataTest.scala:40)
kafka.integration.TopicMetadataTest > testTopicMetadataRequest FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at kafka.integration.TopicMetadataTest.setUp(TopicMetadataTest.scala:40)
kafka.integration.TopicMetadataTest > testBasicTopicMetadata FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at kafka.integration.TopicMetadataTest.setUp(TopicMetadataTest.scala:40)
kafka.integration.TopicMetadataTest > testGetAllTopicMetadata FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at kafka.integration.TopicMetadataTest.setUp(TopicMetadataTest.scala:40)
kafka.metrics.KafkaTimerTest > testKafkaTimer PASSED
kafka.utils.UtilsTest > testSwallow PASSED
kafka.utils.UtilsTest > testCircularIterator PASSED
kafka.utils.UtilsTest > testReadBytes PASSED
kafka.utils.UtilsTest > testReplaceSuffix PASSED
kafka.utils.UtilsTest > testReadInt PASSED
kafka.utils.UtilsTest > testCsvList PASSED
kafka.utils.UtilsTest > testInLock PASSED
kafka.utils.SchedulerTest > testMockSchedulerNonPeriodicTask PASSED
kafka.utils.SchedulerTest > testMockSchedulerPeriodicTask PASSED
kafka.utils.SchedulerTest > testReentrantTaskInMockScheduler PASSED
kafka.utils.SchedulerTest > testNonPeriodicTask PASSED
kafka.utils.SchedulerTest > testPeriodicTask PASSED
kafka.utils.IteratorTemplateTest > testIterator PASSED
kafka.utils.JsonTest > testJsonEncoding PASSED
kafka.message.MessageCompressionTest > testSimpleCompressDecompress PASSED
kafka.message.MessageCompressionTest > testComplexCompressDecompress PASSED
kafka.message.MessageTest > testFieldValues PASSED
kafka.message.MessageTest > testChecksum PASSED
kafka.message.MessageTest > testEquality PASSED
kafka.message.MessageTest > testIsHashable PASSED
kafka.message.ByteBufferMessageSetTest > testWrittenEqualsRead PASSED
kafka.message.ByteBufferMessageSetTest > testIteratorIsConsistent PASSED
kafka.message.ByteBufferMessageSetTest > testSizeInBytes PASSED
kafka.message.ByteBufferMessageSetTest > testWriteTo PASSED
kafka.message.ByteBufferMessageSetTest > testEquals PASSED
kafka.message.ByteBufferMessageSetTest > testIterator PASSED
kafka.message.ByteBufferMessageSetTest > testValidBytes PASSED
kafka.message.ByteBufferMessageSetTest > testValidBytesWithCompression PASSED
kafka.message.ByteBufferMessageSetTest > testOffsetAssignment PASSED
kafka.network.SocketServerTest > simpleRequest PASSED
kafka.network.SocketServerTest > tooBigRequestIsRejected PASSED
kafka.network.SocketServerTest > testNullResponse PASSED
kafka.network.SocketServerTest > testSocketsCloseOnShutdown PASSED
kafka.zk.ZKEphemeralTest > testEphemeralNodeCleanup FAILED
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:144)
at
org.apache.zookeeper.server.NIOServerCnxn$Factory.<init>(NIOServerCnxn.java:125)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:32)
at
kafka.zk.ZooKeeperTestHarness$class.setUp(ZooKeeperTestHarness.scala:33)
at kafka.zk.ZKEphemeralTest.setUp(ZKEphemeralTest.scala:27)
257 tests completed, 28 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:///x1/jenkins/jenkins-slave/workspace/Kafka-trunk/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: 4 mins 21.9 secs
Build step 'Execute shell' marked build as failure
