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/07/14 21:05:30 UTC
[2/5] storm git commit: Remove obsolete TODO
Remove obsolete TODO
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/935e87ac
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/935e87ac
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/935e87ac
Branch: refs/heads/master
Commit: 935e87accc85340549f44effa8a675e950747faa
Parents: b1411aa
Author: Enno Shioji <es...@gmail.com>
Authored: Thu Jul 2 18:56:23 2015 +0100
Committer: Enno Shioji <es...@gmail.com>
Committed: Thu Jul 2 18:56:23 2015 +0100
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/messaging/netty/Context.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/935e87ac/storm-core/src/jvm/backtype/storm/messaging/netty/Context.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/messaging/netty/Context.java b/storm-core/src/jvm/backtype/storm/messaging/netty/Context.java
index 2baad0e..884f115 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Context.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Context.java
@@ -55,7 +55,6 @@ public class Context implements IContext {
int maxWorkers = Utils.getInt(storm_conf.get(Config.STORM_MESSAGING_NETTY_CLIENT_WORKER_THREADS));
ThreadFactory bossFactory = new NettyRenameThreadFactory("client" + "-boss");
ThreadFactory workerFactory = new NettyRenameThreadFactory("client" + "-worker");
- // TODO investigate impact of having one worker
if (maxWorkers > 0) {
clientChannelFactory = new NioClientSocketChannelFactory(Executors.newCachedThreadPool(bossFactory),
Executors.newCachedThreadPool(workerFactory), maxWorkers);