FLUME-1775: FileChannel Log Background worker should catch Throwable (Hari Shreedharan via Brock Noland)
Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/16b9cb5a Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/16b9cb5a Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/16b9cb5a Branch: refs/heads/flume-1.3.0 Commit: 16b9cb5ad5da0639dd4d21f08ee67366ea68873a Parents: 9c5a9a8 Author: Brock Noland <[email protected]> Authored: Tue Dec 11 11:09:55 2012 -0600 Committer: Hari Shreedharan <[email protected]> Committed: Thu Dec 20 00:13:31 2012 -0800 ---------------------------------------------------------------------- .../java/org/apache/flume/channel/file/Log.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/16b9cb5a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java ---------------------------------------------------------------------- diff --git a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java index 829e35a..af11dc5 100644 --- a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java +++ b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java @@ -1035,7 +1035,7 @@ class Log { } } catch (IOException e) { LOG.error("Error doing checkpoint", e); - } catch (Exception e) { + } catch (Throwable e) { LOG.error("General error in checkpoint worker", e); } }
