This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ab784fbfabb Revert "Optimized the query logic to make schema or weak
data query read from local first & random if without local (#15106)" (#15127)
add 50a48ce42b3 Load & Region Migrate: Notify all DNs before and after RM
(#15032)
No new revisions were added by this update.
Summary of changes:
.../client/async/CnToDnAsyncRequestType.java | 1 +
.../CnToDnInternalServiceAsyncRequestManager.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 1 +
.../procedure/env/ConfigNodeProcedureEnv.java | 15 +++
.../region/NotifyRegionMigrationProcedure.java | 137 +++++++++++++++++++++
.../impl/region/RegionMigrateProcedure.java | 2 +
...eState.java => NotifyRegionMigrationState.java} | 5 +-
.../procedure/store/ProcedureFactory.java | 7 ++
.../confignode/procedure/store/ProcedureType.java | 1 +
.../impl/DataNodeInternalRPCServiceImpl.java | 7 ++
.../plan/scheduler/load/LoadTsFileScheduler.java | 10 ++
.../iotdb/db/service/RegionMigrateService.java | 18 +++
.../src/main/thrift/datanode.thrift | 10 ++
13 files changed, 217 insertions(+), 3 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%)
