This is an automated email from the ASF dual-hosted git repository.
Wei-hao-Li pushed a change to branch fixStopDN
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 330a85a5ef3 fix some
add 3a42dddc3f6 Upgrade Docker base image to eclipse-temurin:17-jre-jammy
(#18795)
add d20082b1615 [Misc] Add generic extension points to reduce cross-branch
conflicts (#18683)
add 4473a133d08 Fix table rename on a DataNode that missed the pre-release
(#18800)
add 48233ea92dd [Fix] Isolate FileReaderManager reader I/O with per-file
locks (#18788)
add 59d9e3e10ad Bump at.yawk.lz4:lz4-java from 1.11.1 to 1.11.4 (#18798)
add 620be2861b8 Bump com.fasterxml.jackson.core:jackson-core from 2.18.9
to 2.18.11 (#18789)
add eb0e3f1f208 Fix duplicate DataRegion scheduling after recovery (#18803)
add 1a834815784 Fix read lock leak in disk usage statistics (#18807)
add 94f99d6516a Extend the node state machine and persist node statuses
(#18801)
add cb0269d9fde Standardize ConfigRegionStateMachine log messages (#18811)
add 99a3e06c76b [Fix] Preserve absent local search index during
subscription WAL replay (#18805)
add 83f6428629d Fix subscription WAL replay cursor boundaries (#18810)
add 24fb54f7e77 Bump Thrift to 0.25.0 (#18793)
add 21d53dd015c Bound subscription memory borrowing and report admission
failures (#18812)
add b94aa09ab66 [Fix] Prevent consensus subscription teardown from
blocking unsubscribe (#18804)
add 2b01d119171 Merge branch 'master' of github.com:apache/iotdb into
fixStopDN
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 12 +-
LICENSE-binary | 4 +-
docker/src/main/Dockerfile-1.0.0-confignode | 2 +-
docker/src/main/Dockerfile-1.0.0-datanode | 2 +-
docker/src/main/Dockerfile-1.0.0-standalone | 2 +-
docker/src/main/Dockerfile-1c1d | 2 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 12 +
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 31 +-
.../it/cluster/IoTDBClusterNodeShutdownHookIT.java | 60 +-
.../it/cluster/IoTDBNodeStatusFailoverIT.java | 743 +++++++++++++++++
.../it/cluster/IoTDBNodeStatusPersistenceIT.java | 379 +++++++++
.../confignode/it/cluster/NodeStatusTestAgent.java | 203 +++++
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 3 +-
.../it/partition/IoTDBPartitionCreationIT.java | 58 +-
.../it/partition/IoTDBPartitionDurableIT.java | 49 +-
.../iotdb/pipe/it/single/IoTDBShowReceiversIT.java | 6 +-
.../it/db/it/IoTDBSetSystemStatusTableIT.java | 70 +-
...ableAggregationQueryWithNetworkPartitionIT.java | 5 +-
.../IoTDBTableViewQueryWithCachedDeviceIT.java | 3 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 1 +
.../iotdb/session/it/IoTDBConnectionsIT.java | 53 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 21 +-
...TDBConsensusSubscriptionUnsubscribeTableIT.java | 253 ++++++
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 3 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 3 +
.../org/apache/iotdb/rpc/NonOpenTransport.java | 6 +
.../rpc/TCompressedElasticFramedTransport.java | 4 +
.../apache/iotdb/rpc/TElasticFramedTransport.java | 32 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 22 +
.../iotdb/rpc/TElasticFramedTransportTest.java | 101 +++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 65 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 9 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 9 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 68 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 9 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 18 +-
.../handlers/heartbeat/AINodeHeartbeatHandler.java | 4 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 7 +-
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 3 +
.../request/ConfigPhysicalPlanVisitor.java | 8 +
...sionInfoPlan.java => UpdateNodeStatusPlan.java} | 57 +-
...Plan.java => SetTableColumnPropertiesPlan.java} | 34 +-
.../statemachine/ConfigRegionStateMachine.java | 16 +-
.../iotdb/confignode/manager/ConfigManager.java | 161 ++--
.../apache/iotdb/confignode/manager/IManager.java | 18 +-
.../iotdb/confignode/manager/ProcedureManager.java | 34 +-
.../confignode/manager/RetryFailedTasksThread.java | 3 +-
.../iotdb/confignode/manager/load/LoadManager.java | 76 +-
.../manager/load/balancer/RegionBalancer.java | 12 +-
.../manager/load/cache/AbstractLoadCache.java | 9 +-
.../confignode/manager/load/cache/LoadCache.java | 140 +++-
.../load/cache/consensus/ConsensusGroupCache.java | 3 +-
.../load/cache/node/AINodeHeartbeatCache.java | 48 --
.../manager/load/cache/node/BaseNodeCache.java | 84 +-
.../load/cache/node/ConfigNodeHeartbeatCache.java | 39 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 57 +-
.../load/cache/node/NodeHeartbeatSample.java | 7 +-
.../manager/load/cache/node/NodeStatistics.java | 17 +
.../manager/load/cache/region/RegionCache.java | 3 +-
.../load/cache/region/RegionGroupCache.java | 2 +-
.../manager/load/service/StatisticsService.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 25 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 26 +
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 7 +
.../pipe/source/ConfigRegionListeningFilter.java | 2 +
.../manager/schema/ClusterSchemaManager.java | 55 ++
.../runtime/SubscriptionRuntimeCoordinator.java | 7 +-
.../persistence/executor/ConfigPlanExecutor.java | 82 +-
.../confignode/persistence/node/NodeInfo.java | 115 ++-
.../schema/CNPhysicalPlanGenerator.java | 48 +-
.../persistence/schema/CNSnapshotFileType.java | 4 +-
.../persistence/schema/ClusterSchemaInfo.java | 11 +
.../confignode/persistence/schema/ConfigMTree.java | 22 +
.../procedure/env/ConfigNodeProcedureEnv.java | 7 +-
.../procedure/env/RegionMaintainHandler.java | 2 +-
.../procedure/env/RemoveDataNodeHandler.java | 71 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 1 +
.../impl/node/RemoveDataNodesProcedure.java | 6 +-
.../procedure/impl/schema/SchemaUtils.java | 26 +-
.../table/AbstractAlterOrDropTableProcedure.java | 19 +
...re.java => AbstractSetPropertiesProcedure.java} | 71 +-
.../impl/schema/table/RenameTableProcedure.java | 2 +-
.../table/SetTableColumnPropertiesProcedure.java | 107 +++
.../schema/table/SetTablePropertiesProcedure.java | 218 +----
.../procedure/store/ProcedureFactory.java | 9 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../confignode/service/ConfigNodeShutdownHook.java | 162 +++-
.../heartbeat/DataNodeHeartbeatHandlerTest.java | 100 +++
.../request/ConfigPhysicalPlanSerDeTest.java | 67 ++
.../manager/ConfigManagerShutdownReportTest.java | 161 ++++
.../confignode/manager/ProcedureManagerTest.java | 25 +
.../manager/RetryFailedTasksThreadTest.java | 107 +++
.../confignode/manager/load/LoadManagerTest.java | 115 ++-
.../manager/load/balancer/RegionBalancerTest.java | 144 ++++
.../router/priority/GreedyPriorityTest.java | 2 +-
.../priority/LeaderPriorityBalancerTest.java | 2 +-
.../load/cache/ConsensusGroupCacheTest.java | 2 +-
.../load/cache/LoadCacheNodeStatusTest.java | 336 ++++++++
.../cache/LoadCachePersistedNodeStatusTest.java | 898 +++++++++++++++++++++
.../manager/load/cache/NodeCacheTest.java | 228 +++++-
.../manager/node/NodeManagerStatusReasonTest.java | 133 +++
.../SubscriptionRuntimeCoordinatorTest.java | 119 +++
.../persistence/CNPhysicalPlanGeneratorTest.java | 20 +
.../iotdb/confignode/persistence/NodeInfoTest.java | 269 ++++++
.../procedure/env/ConfigNodeProcedureEnvTest.java | 93 +++
.../procedure/env/RegionMaintainHandlerTest.java | 68 ++
.../impl/node/RemoveDataNodePersistenceTest.java | 581 +++++++++++++
.../procedure/impl/schema/SchemaUtilsTest.java | 91 +++
.../service/ConfigNodeShutdownHookTest.java | 346 ++++++++
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 4 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 4 +
.../subscription/SubscriptionQueueAdmission.java | 18 +-
.../subscription/SubscriptionQueueRegistry.java | 39 +-
.../SubscriptionQueueRejectionReason.java | 42 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 3 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 11 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 4 +
.../iotdb/db/i18n/StorageEngineMessages.java | 6 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 2 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 10 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 4 +
.../iotdb/db/i18n/StorageEngineMessages.java | 6 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 14 +
.../AllowAllLBACAccessControl.java} | 38 +-
.../apache/iotdb/db/lbac/ILBACAccessControl.java | 74 ++
.../request/PipeTransferTabletBatchReqV2.java | 3 +
.../impl/DataNodeInternalRPCServiceImpl.java | 35 +-
.../fragment/FakedFragmentInstanceContext.java | 84 +-
.../fragment/FragmentInstanceContext.java | 181 +++--
.../InformationSchemaContentSupplierFactory.java | 67 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 2 +
.../plan/analyze/schema/SchemaValidator.java | 56 +-
.../execution/config/TableConfigTaskVisitor.java | 69 ++
.../config/executor/ClusterConfigTaskExecutor.java | 56 +-
.../config/executor/IConfigTaskExecutor.java | 9 +
.../config/metadata/ShowClusterDetailsTask.java | 63 +-
.../execution/config/metadata/ShowClusterTask.java | 40 +-
.../config/metadata/ShowConfigNodesTask.java | 28 +-
.../config/metadata/ShowDataNodesTask.java | 30 +-
...java => AlterTableSetColumnPropertiesTask.java} | 18 +-
.../AdditionalInformationSchemaProvider.java | 59 ++
...ditionalInformationSchemaProviderRegistry.java} | 29 +-
.../relational/metadata/TableMetadataImpl.java | 11 +-
.../DataNodeLocationSupplierFactory.java | 9 +
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../sql/ast/DefaultTraversalVisitor.java | 9 +
...ColumnComment.java => SetColumnProperties.java} | 76 +-
.../plan/relational/sql/parser/AstBuilder.java | 4 +
.../relational/sql/util/DataNodeSqlFormatter.java | 25 +
.../plan/statement/crud/InsertRowsStatement.java | 17 +
.../db/schemaengine/table/DataNodeTableCache.java | 27 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 4 +-
.../iotdb/db/storageengine/StorageEngine.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 6 +-
.../schedule/CompactionScheduleTaskManager.java | 10 +-
.../dataregion/memtable/TsFileProcessor.java | 4 +-
.../dataregion/read/control/FileReaderManager.java | 698 ++++++++++------
.../dataregion/tsfile/TsFileLock.java | 27 +-
.../dataregion/utils/DiskUsageStatisticUtil.java | 12 +-
.../dataregion/wal/buffer/WALBuffer.java | 10 +-
.../wal/checkpoint/CheckpointManager.java | 4 +-
.../broker/ConsensusSubscriptionBroker.java | 9 +-
.../consensus/ConsensusPrefetchingQueue.java | 425 +++++++---
.../broker/consensus/ProgressWALIterator.java | 4 +-
...nsensusSubscriptionPrefetchingQueueMetrics.java | 90 +++
.../resource/SubscriptionMemoryManager.java | 335 +++++++-
.../ConsensusSubscriptionPrefetchExecutor.java | 10 +
.../task/subtask/ConsensusPrefetchSubtask.java | 1 +
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 2 +
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 84 --
.../org/apache/iotdb/db/auth/entity/UserTest.java | 53 --
.../DataNodeInternalRPCServiceImplDiskTest.java | 43 +-
...eInternalRPCServiceImplSetSystemStatusTest.java | 91 +++
.../fragment/FileReaderReferenceLifecycleTest.java | 189 +++++
.../RegionQueryInitializationLockTest.java | 280 +++++++
.../fragment/RegionScanTimeSliceTest.java | 96 +++
.../metadata/ShowClusterDetailsTaskTest.java | 172 ++++
.../config/metadata/ShowClusterTaskTest.java | 168 ++++
.../config/metadata/ShowConfigNodesTaskTest.java | 121 +++
.../config/metadata/ShowDataNodesTaskTest.java | 114 +++
.../schemaengine/table/DataNodeTableCacheTest.java | 59 ++
.../buffer/TimeSeriesMetadataCacheTest.java | 4 +-
.../control/FileReaderManagerConcurrencyTest.java | 871 ++++++++++++++++++++
.../dataregion/tsfile/TsFileLockTest.java | 108 +++
.../dataregion/utils/TableDiskUsageTest.java | 8 +
.../wal/buffer/WALBufferRollRecoveryTest.java | 4 +-
.../rescon/disk/FolderManagerTest.java | 57 +-
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 249 +++++-
.../ConsensusPrefetchingQueueSeekTest.java | 241 ++++++
.../consensus/ConsensusPrefetchingQueueTest.java | 351 +++++++-
...nsensusPrefetchingQueueWalBackpressureTest.java | 19 +-
.../broker/consensus/ProgressWALIteratorTest.java | 76 +-
...susSubscriptionPrefetchingQueueMetricsTest.java | 23 +
.../resource/SubscriptionMemoryManagerTest.java | 108 +++
.../conf/iotdb-system.properties.template | 29 +
.../apache/iotdb/commons/i18n/LBACMessages.java} | 27 +-
.../apache/iotdb/commons/i18n/LBACMessages.java} | 27 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 64 --
.../org/apache/iotdb/commons/auth/entity/User.java | 64 --
.../commons/auth/role/LocalFileRoleAccessor.java | 69 +-
.../commons/auth/user/LocalFileUserAccessor.java | 6 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 102 ++-
.../apache/iotdb/commons/cluster/RegionStatus.java | 5 +
.../apache/iotdb/commons/conf/CommonConfig.java | 57 +-
.../apache/iotdb/commons/disk/FolderManager.java | 14 +-
.../commons/disk/strategy/DirectoryStrategy.java | 4 +-
.../commons/enums/HandleSystemErrorStrategy.java | 6 +-
.../commons/lbac/LBACAccessDeniedException.java | 56 ++
.../iotdb/commons/lbac/LBACRuntimeException.java} | 15 +-
.../apache/iotdb/commons/lbac/RequiredLabels.java | 79 ++
.../operation/LabelAccessType.java} | 8 +-
.../execution/MemoryEstimationHelper.java | 13 +
.../plan/relational/metadata/ColumnSchema.java | 13 +-
.../schema/column/ColumnHeaderConstant.java | 2 +
.../table/AlterOrDropTableOperationType.java | 5 +-
.../commons/schema/table/InformationSchema.java | 41 +
.../apache/iotdb/commons/schema/table/TsTable.java | 2 +
.../iotdb/commons/service/metric/enums/Metric.java | 8 +
.../iotdb/commons/service/metric/enums/Tag.java | 1 +
.../iotdb/commons/cluster/NodeStatusTest.java | 91 +++
.../iotdb/commons/conf/CommonConfigTest.java | 222 ++++-
.../src/main/thrift/confignode.thrift | 21 +-
pom.xml | 8 +-
225 files changed, 13746 insertions(+), 2038 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBNodeStatusFailoverIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBNodeStatusPersistenceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/NodeStatusTestAgent.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionUnsubscribeTableIT.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/confignode/{UpdateVersionInfoPlan.java
=> UpdateNodeStatusPlan.java} (56%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{SetTablePropertiesPlan.java
=> SetTableColumnPropertiesPlan.java} (67%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/{SetTablePropertiesProcedure.java
=> AbstractSetPropertiesProcedure.java} (76%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTableColumnPropertiesProcedure.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/client/async/handlers/heartbeat/DataNodeHeartbeatHandlerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerShutdownReportTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/RetryFailedTasksThreadTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/RegionBalancerTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/LoadCacheNodeStatusTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/LoadCachePersistedNodeStatusTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/node/NodeManagerStatusReasonTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/subscription/runtime/SubscriptionRuntimeCoordinatorTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnvTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodePersistenceTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/SchemaUtilsTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/service/ConfigNodeShutdownHookTest.java
copy
external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/Message.java =>
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueAdmission.java
(71%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueRejectionReason.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/planner/ir/ExpressionNodeInliner.java
=> lbac/AllowAllLBACAccessControl.java} (51%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/lbac/ILBACAccessControl.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{AlterTableCommentColumnTask.java
=> AlterTableSetColumnPropertiesTask.java} (77%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/information/AdditionalInformationSchemaProvider.java
copy
iotdb-core/{calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/NaryComputation.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/information/AdditionalInformationSchemaProviderRegistry.java}
(57%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{SetColumnComment.java
=> SetColumnProperties.java} (63%)
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/RoleTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/UserTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplSetSystemStatusTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/FileReaderReferenceLifecycleTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/RegionQueryInitializationLockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/RegionScanTimeSliceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterDetailsTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowConfigNodesTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowDataNodesTaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/control/FileReaderManagerConcurrencyTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileLockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueSeekTest.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/query/OutOfTTLException.java
=>
node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/LBACMessages.java}
(51%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/query/OutOfTTLException.java
=>
node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/LBACMessages.java}
(51%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/LBACAccessDeniedException.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/ainode/ModelException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/lbac/LBACRuntimeException.java}
(72%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/RequiredLabels.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{auth/entity/ModelType.java
=> lbac/operation/LabelAccessType.java} (89%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/cluster/NodeStatusTest.java
