You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Tom White (JIRA)" <ji...@apache.org> on 2011/08/13 07:14:27 UTC
[jira] [Updated] (FLUME-742) TestAvroSinks fails
[ 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