wangxj3 commented on issue #15983: URL: https://github.com/apache/dolphinscheduler/issues/15983#issuecomment-2109138599
>  look at here.the connection is runnig here for many days(I obersevered many connections that as same as this).because the channels(a map that store all the channels ) lose the quote of the channel forever, it can't close because we cann't get the channel anymore as the channel losed when channels.put(host,channel) called. When tasks are concurrent (tasks running on the same worker-server), the tasks are A and B. Concurrency occurs when creating channels. NettyRemotingClient.createChannel is called. A creates channelA, B creates channelB, and A uses channelA to send messages, B uses channelB to send messages, but when A closes channel, it takes the channel by host,so get the channel of channelB, and channelB is closed. channelA is free. 当任务出现并发（同一个worker-server运行的任务），任务为A，B，在创建channel的时候出现了并发，调用NettyRemotingClient.createChannel，A创建了channelA，B创建了channelB，A用channelA发送消息，B用channelB发送消息，但是A在关闭的时候根据host拿channel，关闭的是channelB。channelA就游离了。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
