This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch codex/ratis-historical-replay-20261029
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e2d213723e2 Restore ConfigNode descriptor imports
add 6a0c76d4f20 Revert "Disable Pipe and Subscription with Ratis"
add d1b7ed27b50 Refine Ratis Pipe and Subscription restrictions
No new revisions were added by this update.
Summary of changes:
.../iotdb/confignode/manager/ConfigManager.java | 38 ++++++++++++------
.../manager/pipe/agent/PipeConfigNodeAgent.java | 33 +++++++++++++++-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 5 ---
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 5 ---
.../runtime/PipeRuntimeCoordinator.java | 39 +++++++-----------
.../pipe/coordinator/task/PipeTaskCoordinator.java | 45 +++++++++++++++++++++
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 9 -----
.../subscription/SubscriptionCoordinator.java | 2 +-
.../runtime/SubscriptionLeaderChangeHandler.java | 4 +-
.../iotdb/db/pipe/agent/PipeDataNodeAgent.java | 33 +++++++++++++++-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 4 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 20 +++-------
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 6 +--
.../task/execution/PipeSubtaskExecutorManager.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 24 ++++++++++-
...istoricalDataRegionTsFileAndDeletionSource.java | 9 +++++
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 24 ++++-------
.../impl/DataNodeInternalRPCServiceImpl.java | 8 +---
.../config/executor/ClusterConfigTaskExecutor.java | 43 ++++++++++----------
.../java/org/apache/iotdb/db/service/DataNode.java | 7 ++--
.../agent/SubscriptionReceiverAgent.java | 12 +++---
.../agent/SubscriptionRuntimeAgent.java | 8 +---
.../ConsensusSubscriptionSetupHandler.java | 4 +-
...nsensusSubscriptionPrefetchExecutorManager.java | 4 +-
.../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 29 ++++++++++++++
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 24 -----------
...ricalDataRegionTsFileAndDeletionSourceTest.java | 46 ++++++++++++++++++++++
.../apache/iotdb/commons/i18n/PipeMessages.java | 7 +++-
.../apache/iotdb/commons/i18n/PipeMessages.java | 7 +++-
.../commons/pipe/agent/task/PipeTaskAgent.java | 16 ++++----
.../options/PipeInclusionOptionsTest.java | 27 +++++++++++++
31 files changed, 357 insertions(+), 187 deletions(-)
