Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.1.0
-
None
Description
If AvroSink and perhaps others, if any non-caught exception is thrown before transaction.commit, the finally clause throws:
2012-03-28 17:31:24,560 ERROR org.apache.flume.SinkRunner: Unhandled exception, logging and sleeping for 5000ms
java.lang.IllegalStateException: close() called when transaction is OPEN - you must either commit or rollback first
at com.google.common.base.Preconditions.checkState(Preconditions.java:172)
at org.apache.flume.channel.BasicTransactionSemantics.close(BasicTransactionSemantics.java:179)
at org.apache.flume.sink.AvroSink.process(AvroSink.java:269)
at org.apache.flume.sink.FailoverSinkProcessor.process(FailoverSinkProcessor.java:118)
at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:148)
at java.lang.Thread.run(Thread.java:662)