ChannelProcessor needs to check for null before calling rollback
----------------------------------------------------------------

                 Key: FLUME-1131
                 URL: https://issues.apache.org/jira/browse/FLUME-1131
             Project: Flume
          Issue Type: Bug
            Reporter: Brock Noland
             Fix For: v1.2.0


If an Exception is thrown in ChannelProcessor.processEvent whilst getting an 
exception, tx will be null and when rollback is called on tx, an NPE will be 
thrown.

{noformat}
12/04/18 19:03:17 ERROR source.PollableSourceRunner: Unhandled exception, 
logging and sleeping for 5000ms
java.lang.NullPointerException
        at 
org.apache.flume.channel.ChannelProcessor.processEvent(ChannelProcessor.java:183)
        at 
org.apache.flume.source.SequenceGeneratorSource.process(SequenceGeneratorSource.java:48)
        at 
org.apache.flume.source.PollableSourceRunner$PollingRunner.run(PollableSourceRunner.java:131)
        at java.lang.Thread.run(Thread.java:662)
{noformat}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: 
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Reply via email to