This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit 79d209b3b3f Revert "Merge branch 'dev/1.3' of
https://github.com/apache/iotdb into dev/1.3"
omit e1bd3fd8a43 Merge branch 'dev/1.3' of https://github.com/apache/iotdb
into dev/1.3
omit f019f2627c6 [To dev/1.3] Print debug log only if debug is enbale
omit 7cd373036cb RegionMigrateProcedure and RegionReconstructProcedure no
longer acquire lock #15122 (#15146)
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/dev/1.3 (50cc5da0738)
\
O -- O -- O (79d209b3b3f)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../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 ++++++++---
...eState.java => NotifyRegionMigrationState.java} | 5 +-
.../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} | 42 +++----
.../resource/log/SubscriptionLogManager.java} | 16 +--
.../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, 513 insertions(+), 101 deletions(-)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/NotifyRegionMigrationProcedure.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{RemoveAINodeState.java
=> NotifyRegionMigrationState.java} (93%)
copy
iotdb-core/{metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/SystemType.java
=>
datanode/src/main/java/org/apache/iotdb/db/subscription/resource/SubscriptionDataNodeResourceManager.java}
(55%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/log/PipeLogManager.java
=>
datanode/src/main/java/org/apache/iotdb/db/subscription/resource/log/SubscriptionLogManager.java}
(71%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/resource/log/SubscriptionLogStatus.java
