This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b4852c91c52 IoTV2: Try to fix tsfile corruption & receiver dir clean
(#15410)
add acdf8cc0f9a ShutdownNow all pipe connector subTask works to interrupt
all threads blocking in lock. (#15411)
No new revisions were added by this update.
Summary of changes:
.../task/execution/PipeSubtaskExecutorManager.java | 7 +
.../pipeconsensus/PipeConsensusAsyncConnector.java | 157 +++++++++++++++------
.../iotdb/db/service/DataNodeShutdownHook.java | 4 +
.../agent/task/execution/PipeSubtaskExecutor.java | 2 +-
4 files changed, 123 insertions(+), 47 deletions(-)
