This is an automated email from the ASF dual-hosted git repository.
zikun pushed a change to branch rm-load-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d8082b07c7f fix
add 150ae824a90 Region migration notify all DNs
No new revisions were added by this update.
Summary of changes:
.../client/async/CnToDnAsyncRequestType.java | 1 +
.../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 | 34 +++++
.../src/main/thrift/datanode.thrift | 10 ++
12 files changed, 227 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%)
