[
https://issues.apache.org/jira/browse/IOTDB-3890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608113#comment-17608113
]
Jinrui Zhang commented on IOTDB-3890:
-------------------------------------
We will introduce the add/remove peer for MultiLeader in this PR
https://github.com/apache/iotdb/pull/7390
And after that, this issue will be fixed
> [ shrink ] Other datanodes still send logs to the nodes that have been scaled
> down
> ----------------------------------------------------------------------------------
>
> Key: IOTDB-3890
> URL: https://issues.apache.org/jira/browse/IOTDB-3890
> Project: Apache IoTDB
> Issue Type: Bug
> Components: mpp-cluster
> Affects Versions: 0.14.0-SNAPSHOT
> Reporter: 刘珍
> Assignee: Jinrui Zhang
> Priority: Major
>
> 172.20.70.3 是缩容停掉的datanode，其他节点还持续往这个节点同步日志（WARN）：
> {color:red}*弱一致协议，还不支持缩容*{color}
> 2022-07-19 16:22:59,446 [TAsyncClientManager#SelectorThread 51] WARN
> o.a.i.c.m.c.DispatchLogHandler:67 - Can not send
> PendingBatch{startIndex=584463, endIndex=584502, size=40} to peer for
> Peer{groupId=DataRegion[2], endpoint=TEndPoint(ip:172.20.70.3, port:40010)}
> times 336 because {}
> java.net.ConnectException: Connection refused
> at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> at
> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> at
> org.apache.thrift.transport.TNonblockingSocket.finishConnect(TNonblockingSocket.java:217)
> at
> org.apache.thrift.async.TAsyncMethodCall.doConnecting(TAsyncMethodCall.java:279)
> at
> org.apache.thrift.async.TAsyncMethodCall.transition(TAsyncMethodCall.java:189)
> at
> org.apache.thrift.async.TAsyncClientManager$SelectThread.transitionMethods(TAsyncClientManager.java:143)
> at
> org.apache.thrift.async.TAsyncClientManager$SelectThread.run(TAsyncClientManager.java:113)
> 复现流程同
> https://issues.apache.org/jira/browse/IOTDB-3887
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
