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 1722b533d1c [Bugfix] Replay Ratis historical TsFiles without Pipe
progress
add 7d4912d72d1 Disable Pipe and Subscription with Ratis
add 2d047dc1009 Fix consumer group response handling in topic procedures
(#19047)
add a927dd6bc63 Fix ZH locale CI ZIP dependencies by building through
package (#19050)
add ab770467c8e Fix DataRegion snapshot failures when hard links are
unavailable (#19049)
add 28c5028bb46 Suppress duplicate database warning for pipe snapshots
(#19054)
add abadc645db9 Merge remote-tracking branch 'origin/master' into
codex/ratis-historical-replay-20261029
No new revisions were added by this update.
Summary of changes:
.github/workflows/zh-locale-compile.yml | 3 +-
.../iotdb/confignode/manager/ConfigManager.java | 29 +++++--
.../manager/pipe/agent/PipeConfigNodeAgent.java | 7 ++
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 5 ++
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 6 +-
.../runtime/PipeRuntimeCoordinator.java | 39 +++++----
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 10 ++-
.../subscription/SubscriptionCoordinator.java | 7 +-
.../runtime/SubscriptionLeaderChangeHandler.java | 9 ++-
.../subscription/topic/AlterTopicProcedure.java | 9 ++-
.../subscription/topic/DropTopicProcedure.java | 9 ++-
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 3 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 3 +
.../consensus/iot/IoTConsensusServerImpl.java | 6 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 2 +
.../iotdb/db/i18n/StorageEngineMessages.java | 2 +
.../iotdb/db/pipe/agent/PipeDataNodeAgent.java | 7 ++
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 4 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 20 +++--
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 6 ++
.../task/execution/PipeSubtaskExecutorManager.java | 4 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 9 +++
...istoricalDataRegionTsFileAndDeletionSource.java | 9 ---
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 29 ++++++-
.../impl/DataNodeInternalRPCServiceImpl.java | 31 ++++---
.../config/executor/ClusterConfigTaskExecutor.java | 31 +++++++
.../java/org/apache/iotdb/db/service/DataNode.java | 9 ++-
.../dataregion/snapshot/SnapshotFileUtils.java | 49 +++++++++++
.../dataregion/snapshot/SnapshotLoader.java | 2 +-
.../dataregion/snapshot/SnapshotTaker.java | 8 +-
.../agent/SubscriptionReceiverAgent.java | 21 ++++-
.../agent/SubscriptionRuntimeAgent.java | 6 ++
.../ConsensusSubscriptionSetupHandler.java | 7 +-
...nsensusSubscriptionPrefetchExecutorManager.java | 8 +-
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 24 ++++++
...ricalDataRegionTsFileAndDeletionSourceTest.java | 46 -----------
.../dataregion/snapshot/SnapshotFileUtilsTest.java | 94 ++++++++++++++++++++++
.../agent/SubscriptionReceiverAgentTest.java | 30 +++++++
.../apache/iotdb/commons/i18n/PipeMessages.java | 3 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 3 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 12 +++
41 files changed, 498 insertions(+), 123 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/snapshot/SnapshotFileUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/snapshot/SnapshotFileUtilsTest.java
