From a2d245ddc1cb3eabb6fa51eab407ddfae5c6cb8f Mon Sep 17 00:00:00 2001 From: CalvinKirs Date: Sun, 24 Jan 2021 22:04:27 +0800 Subject: [PATCH] add rpc config --- .../dolphinscheduler/remote/rpc/remote/NettyServerHandler.java | 1 + 1 file changed, 1 insertion(+) 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());