Santiago M. Mola created FLUME-2529:
---------------------------------------
Summary: Kafka Source test fails: testBatchTime
Key: FLUME-2529
URL: https://issues.apache.org/jira/browse/FLUME-2529
Project: Flume
Issue Type: Bug
Affects Versions: v1.6.0
Environment: Jenkins CI environment
Reporter: Santiago M. Mola
Fix For: v1.6.0
Stacktrace:
java.lang.AssertionError
at org.junit.Assert.fail(Assert.java:92)
at org.junit.Assert.assertTrue(Assert.java:43)
at org.junit.Assert.assertTrue(Assert.java:54)
at
org.apache.flume.source.kafka.TestKafkaSource.testBatchTime(TestKafkaSource.java:197)
Relevant log section might be:
2014-10-29 11:24:23,190 (kafka-processor-6667-2) [ERROR -
kafka.utils.Logging$class.error(Logging.scala:103)] Closing socket for
/127.0.0.1 because of error
java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:197)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379)
at kafka.utils.Utils$.read(Utils.scala:375)
at
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
at kafka.network.Processor.read(SocketServer.scala:347)
at kafka.network.Processor.run(SocketServer.scala:245)
at java.lang.Thread.run(Thread.java:745)
(Attached you'll find the full log)
Note that this is being executed in an Jenkins environment with lots of other
Hadoop stuff being run, so conflicts on ports (Kafka, ZooKeeper) are likely.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
