[FLUME-1131] ChannelProcessor does not handle transactions appropriately

• Type: Bug
• Status: Patch Available
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.1.0
• Assignee: Brock Noland
• Reporter: Brock Noland
• Created: 19/Apr/12 00:08
• Updated: 05/May/12 16:33

Description

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.

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)

Issue Links

• incorporates: FLUME-1133 ChannelProcessor.processEventBatch does not handle Transaction appropriately when a non-ChannelException is thrown