You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/11/13 16:50:56 UTC
[3/7] storm git commit: Some fixes to improve performance
Some fixes to improve performance
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/120840d4
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/120840d4
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/120840d4
Branch: refs/heads/master
Commit: 120840d473d1c68c0e90d27b883b53adf2ea0393
Parents: a99016c
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Wed Nov 11 08:11:10 2015 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Wed Nov 11 08:11:10 2015 -0600
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/120840d4/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java b/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
index 4519162..47d4165 100644
--- a/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
+++ b/storm-core/src/jvm/backtype/storm/utils/DisruptorQueue.java
@@ -65,7 +65,7 @@ public class DisruptorQueue implements IStatefulObject {
private static class FlusherPool {
private Timer _timer = new Timer("disruptor-flush-trigger", true);
- private ThreadPoolExecutor _exec = new ThreadPoolExecutor(1, 100, 10, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(1024));
+ private ThreadPoolExecutor _exec = new ThreadPoolExecutor(1, 100, 10, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(1024), new ThreadPoolExecutor.DiscardPolicy());
private HashMap<Long, ArrayList<Flusher>> _pendingFlush = new HashMap<>();
private HashMap<Long, TimerTask> _tt = new HashMap<>();
@@ -92,8 +92,8 @@ public class DisruptorQueue implements IStatefulObject {
if (tasks != null) {
_exec.invokeAll(tasks);
}
- } catch (Exception e) {
- LOG.error("Could not invoke all ", e);
+ } catch (InterruptedException e) {
+ //Ignored
}
}