flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zentol <...@git.apache.org>
Subject [GitHub] flink pull request #4644: [FLINK-7581] [REST] Name netty threads
Date Wed, 06 Sep 2017 14:06:44 GMT
Github user zentol commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4644#discussion_r137277278
  
    --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java
---
    @@ -104,8 +105,8 @@ protected void initChannel(SocketChannel ch) {
     			}
     		};
     
    -		NioEventLoopGroup bossGroup = new NioEventLoopGroup(1);
    -		NioEventLoopGroup workerGroup = new NioEventLoopGroup();
    +		NioEventLoopGroup bossGroup = new NioEventLoopGroup(1, new DefaultThreadFactory("flink-rest-server-netty-boss"));
    +		NioEventLoopGroup workerGroup = new NioEventLoopGroup(1, new DefaultThreadFactory("flink-rest-server-netty-worker"));
     
    --- End diff --
    
    ah i misread the netty source, will revert it.


---

Mime
View raw message