Repository: storm Updated Branches: refs/heads/1.x-branch f762dbf98 -> 38dc90a69
STORM-2705: DRPCSpout should not sleep itself if no request was fetched as the ISpoutWaitStrategy handles this case. Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b656c0e6 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b656c0e6 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b656c0e6 Branch: refs/heads/1.x-branch Commit: b656c0e6014e46e7f656682591ab5a8763de6b2c Parents: f762dbf Author: sakanaou <[email protected]> Authored: Thu Aug 24 09:58:42 2017 +0200 Committer: Jungtaek Lim <[email protected]> Committed: Fri Aug 25 14:45:13 2017 +0900 ---------------------------------------------------------------------- storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java | 6 ------ 1 file changed, 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/b656c0e6/storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java b/storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java index 791fc91..e95e377 100644 --- a/storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java +++ b/storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java @@ -170,7 +170,6 @@ public class DRPCSpout extends BaseRichSpout { @Override public void nextTuple() { - boolean gotRequest = false; if(_local_drpc_id==null) { int size; synchronized (_clients) { @@ -193,7 +192,6 @@ public class DRPCSpout extends BaseRichSpout { returnInfo.put("id", req.get_request_id()); returnInfo.put("host", client.getHost()); returnInfo.put("port", client.getPort()); - gotRequest = true; _collector.emit(new Values(req.get_func_args(), JSONValue.toJSONString(returnInfo)), new DRPCMessageId(req.get_request_id(), i)); break; } @@ -218,7 +216,6 @@ public class DRPCSpout extends BaseRichSpout { returnInfo.put("id", req.get_request_id()); returnInfo.put("host", _local_drpc_id); returnInfo.put("port", 0); - gotRequest = true; _collector.emit(new Values(req.get_func_args(), JSONValue.toJSONString(returnInfo)), new DRPCMessageId(req.get_request_id(), 0)); } } catch (AuthorizationException aze) { @@ -228,9 +225,6 @@ public class DRPCSpout extends BaseRichSpout { } } } - if(!gotRequest) { - Utils.sleep(1); - } } @Override
