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 d1b7ed27b50 Refine Ratis Pipe and Subscription restrictions
add eab49c25efe Fix Ratis pipe recovery and receiver validation gaps
No new revisions were added by this update.
Summary of changes:
.../manager/pipe/agent/PipeConfigNodeAgent.java | 4 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 6 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 18 +++
.../agent/task/PipeConfigNodeTaskAgentTest.java | 118 ++++++++++++++++
.../persistence/pipe/PipeTaskInfoRatisTest.java | 157 +++++++++++++++++++++
.../iotdb/db/pipe/agent/PipeDataNodeAgent.java | 4 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 1 +
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 14 ++
.../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 68 ++++++++-
.../legacy/IoTDBLegacyPipeReceiverAgentTest.java | 72 ++++++++++
.../options/PipeInclusionOptions.java | 11 ++
.../options/PipeInclusionOptionsTest.java | 14 ++
12 files changed, 480 insertions(+), 7 deletions(-)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTaskAgentTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfoRatisTest.java
