diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyServerHandler.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyServerHandler.java index f5ab779928..9556ec1891 100644 --- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyServerHandler.java +++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyServerHandler.java @@ -71,6 +71,7 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter { logger.info("accept heartbeat msg"); return; } + //todo 使用业务线程池去处理 不要占用netty的资源 response.setRequestId(req.getRequestId());