minor
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/63518be1 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/63518be1 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/63518be1 Branch: refs/heads/master Commit: 63518be11275104314dcebbf83bb1f8a513891ee Parents: a70195d Author: zhuoliu <[email protected]> Authored: Wed Apr 13 13:08:19 2016 -0500 Committer: zhuoliu <[email protected]> Committed: Wed Apr 13 13:08:19 2016 -0500 ---------------------------------------------------------------------- storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/63518be1/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java b/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java index d310337..d09b831 100644 --- a/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java +++ b/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java @@ -145,8 +145,8 @@ public class DisruptorQueue implements IStatefulObject { if (_enableBackpressure && _cb != null && (_metrics.population() + _overflowCount.get()) >= _highWaterMark) { try { if (!_throttleOn) { - _cb.highWaterMark(); _throttleOn = true; + _cb.highWaterMark(); } } catch (Exception e) { throw new RuntimeException("Exception during calling highWaterMark callback!", e); @@ -199,8 +199,8 @@ public class DisruptorQueue implements IStatefulObject { if (_enableBackpressure && _cb != null && (_metrics.population() + _overflowCount.get()) >= _highWaterMark) { try { if (!_throttleOn) { - _cb.highWaterMark(); _throttleOn = true; + _cb.highWaterMark(); } } catch (Exception e) { throw new RuntimeException("Exception during calling highWaterMark callback!", e);
