This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3a9855efa52 Subscription: mark topic as completed when there is no
corresponding prefetching queue (#15433)
add 750f1deb877 Revert "ShutdownNow all pipe connector subTask works to
interrupt all threads blocking in lock. (#15411)" (#15462)
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, 47 insertions(+), 123 deletions(-)
