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.
---
