This is an automated email from the ASF dual-hosted git repository. shoorz pushed a commit to branch dev/1.3 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e1bd3fd8a43816b0c6748d38f0fba733f3e06b6c Merge: f019f2627c6 50cc5da0738 Author: MiniSho <[email protected]> AuthorDate: Tue Mar 25 19:15:40 2025 +0800 Merge branch 'dev/1.3' of https://github.com/apache/iotdb into dev/1.3 .../client/async/CnToDnAsyncRequestType.java | 1 + .../CnToDnInternalServiceAsyncRequestManager.java | 6 + .../rpc/DataNodeAsyncRequestRPCHandler.java | 1 + .../receiver/protocol/IoTDBConfigNodeReceiver.java | 28 ++++- .../procedure/PartitionTableAutoCleaner.java | 3 + .../procedure/TimeoutExecutorThread.java | 2 +- .../procedure/env/ConfigNodeProcedureEnv.java | 15 +++ .../region/NotifyRegionMigrationProcedure.java | 137 +++++++++++++++++++++ .../impl/region/RegionMigrateProcedure.java | 2 + .../impl/schema/UnsetTemplateProcedure.java | 74 ++++++++--- .../state/NotifyRegionMigrationState.java | 24 ++++ .../procedure/store/ProcedureFactory.java | 7 ++ .../confignode/procedure/store/ProcedureType.java | 1 + iotdb-core/datanode/pom.xml | 2 +- .../protocol/opcda/OpcDaServerHandle.java | 5 +- .../async/IoTDBDataRegionAsyncConnector.java | 29 +++-- .../impl/DataNodeInternalRPCServiceImpl.java | 8 +- .../plan/scheduler/load/LoadTsFileScheduler.java | 10 ++ .../template/TemplateInternalRPCUpdateType.java | 1 - .../iotdb/db/service/RegionMigrateService.java | 18 +++ .../agent/SubscriptionBrokerAgent.java | 10 +- .../db/subscription/broker/SubscriptionBroker.java | 25 ++-- .../broker/SubscriptionPrefetchingQueue.java | 11 +- .../SubscriptionDataNodeResourceManager.java | 43 +++++++ .../resource/log/SubscriptionLogManager.java | 39 ++++++ .../resource/log/SubscriptionLogStatus.java | 82 ++++++++++++ .../db/utils/datastructure/AlignedTVList.java | 7 +- .../apache/iotdb/commons/conf/CommonConfig.java | 21 +++- .../iotdb/commons/conf/CommonDescriptor.java | 10 ++ .../subscription/config/SubscriptionConfig.java | 12 ++ .../src/main/thrift/datanode.thrift | 10 ++ pom.xml | 13 +- 32 files changed, 591 insertions(+), 66 deletions(-)
