[
https://issues.apache.org/jira/browse/FLUME-742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom White updated FLUME-742:
----------------------------
Attachment: FLUME-742.patch
The problem is that the AvroEventSink is being closed before its byte count is
retrieved, and closing causes the underlying transport to be nulled out.
However, with this fix there is another error:
{noformat}
java.lang.AssertionError: expected:<25000> but was:<44750>
at org.junit.Assert.fail(Assert.java:91)
at org.junit.Assert.failNotEquals(Assert.java:645)
at org.junit.Assert.assertEquals(Assert.java:126)
at org.junit.Assert.assertEquals(Assert.java:470)
at org.junit.Assert.assertEquals(Assert.java:454)
at
com.cloudera.flume.handlers.avro.TestAvroSinks.testManyThreadsAvroSend(TestAvroSinks.java:220)
{noformat}
The number of bytes is higher than expected for some reason. Anyone know what's
going on here?
> TestAvroSinks fails
> -------------------
>
> Key: FLUME-742
> URL: https://issues.apache.org/jira/browse/FLUME-742
> Project: Flume
> Issue Type: Bug
> Reporter: Tom White
> Attachments: FLUME-742.patch
>
>
> The following appears in the log
> {noformat}
> 2011-08-12 21:21:48,784 [Thread-13] INFO avro.AvroEventSink: AvroEventSink
> open on port 35854
> 2011-08-12 21:21:48,863 [Thread-13] INFO debug.MemorySinkSource: Closing mem
> source sink that has 25 elements
> 2011-08-12 21:21:48,863 [Thread-13] INFO avro.AvroEventSink: AvroEventSink on
> port 35854 closed
> Exception in thread "Thread-13" java.lang.NullPointerException
> at
> com.cloudera.flume.handlers.avro.AvroEventSink.getSentBytes(AvroEventSink.java:116)
> at
> com.cloudera.flume.handlers.avro.TestAvroSinks$3.run(TestAvroSinks.java:196)
> {noformat}
> Then the test (testManyThreadsAvroSend) times out.
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
