You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2015/10/21 16:00:17 UTC
flink git commit: [FLINK-2886] [runtime] Fix config key for number of
threads in NettyClient
Repository: flink
Updated Branches:
refs/heads/master 4c1cffd9d -> 30c46ed13
[FLINK-2886] [runtime] Fix config key for number of threads in NettyClient
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/30c46ed1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/30c46ed1
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/30c46ed1
Branch: refs/heads/master
Commit: 30c46ed134b6660f4099973832074ab809ffa0d1
Parents: 4c1cffd
Author: Ufuk Celebi <uc...@apache.org>
Authored: Wed Oct 21 15:59:42 2015 +0200
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Wed Oct 21 15:59:58 2015 +0200
----------------------------------------------------------------------
.../org/apache/flink/runtime/io/network/netty/NettyClient.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/30c46ed1/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
index fd6d980..6cab15d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java
@@ -147,7 +147,7 @@ class NettyClient {
// multiple clients running on the same host.
String name = NettyConfig.CLIENT_THREAD_GROUP_NAME + " (" + config.getServerPort() + ")";
- EpollEventLoopGroup epollGroup = new EpollEventLoopGroup(config.getServerNumThreads(), NettyServer.getNamedThreadFactory(name));
+ EpollEventLoopGroup epollGroup = new EpollEventLoopGroup(config.getClientNumThreads(), NettyServer.getNamedThreadFactory(name));
bootstrap.group(epollGroup).channel(EpollSocketChannel.class);
}