This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch 1.2-pipe-async-handle-heartbeat
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b804f5e4a23 Pipe: async execute pipeHandleLeaderChange and
pipeHandleLeaderChange to avoid causing heartbeats to timeout
add 80d305eaa2d Pipe: async execute pipeHandleLeaderChange and
pipeHandleMetaChange to avoid causing heartbeats to timeout
No new revisions were added by this update.
Summary of changes:
.../iotdb/confignode/manager/ProcedureManager.java | 6 +-
.../pipe/runtime/PipeHeartbeatParser.java} | 246 ++++++---------------
...ordinator.java => PipeLeaderChangeHandler.java} | 41 +---
.../manager/pipe/runtime/PipeMetaSyncer.java | 4 +-
.../pipe/runtime/PipeRuntimeCoordinator.java | 68 ++----
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 2 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 174 +--------------
.../runtime/PipeHandleMetaChangeProcedureTest.java | 7 +-
.../iotdb/commons/concurrent/ThreadName.java | 18 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 2 +-
10 files changed, 115 insertions(+), 453 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/{procedure/impl/pipe/runtime/PipeHandleMetaChangeProcedure.java
=> manager/pipe/runtime/PipeHeartbeatParser.java} (51%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/runtime/{PipeRuntimeCoordinator.java
=> PipeLeaderChangeHandler.java} (74%)
