You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/03/01 06:13:23 UTC

[iotdb] 01/01: Merge remote-tracking branch 'origin/master' into geely_car_0206

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch geely_car_0206
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 28aa4d52e16649d2eede2f6bd65631669a9eba01
Merge: b8ef8bc5c6 388df2ff4c
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Wed Mar 1 14:10:04 2023 +0800

    Merge remote-tracking branch 'origin/master' into geely_car_0206

 .../iotdb/confignode/conf/ConfigNodeConfig.java    |  10 +-
 .../request/write/datanode/UpdateDataNodePlan.java |  32 ++++--
 ...eMachine.java => ConfigRegionStateMachine.java} |  89 ++++++---------
 .../iotdb/confignode/manager/ConfigManager.java    |  23 +---
 .../apache/iotdb/confignode/manager/IManager.java  |   9 --
 .../manager/consensus/ConsensusManager.java        |  20 ++--
 .../manager/node/ClusterNodeStartUtils.java        |  88 +++++++++------
 .../iotdb/confignode/manager/node/NodeManager.java |  55 ++-------
 .../confignode/persistence/node/NodeInfo.java      |   6 +-
 .../partition/DatabasePartitionTable.java          |   2 +-
 .../procedure/env/ConfigNodeProcedureEnv.java      |   2 +-
 .../procedure/env/DataNodeRemoveHandler.java       |   2 +-
 .../impl/schema/DeleteDatabaseProcedure.java       |  13 ++-
 .../iotdb/confignode/service/ConfigNode.java       |   4 +-
 .../thrift/ConfigNodeRPCServiceProcessor.java      |  21 +---
 .../request/ConfigPhysicalPlanSerDeTest.java       |  16 ++-
 consensus/README.md                                |   2 +-
 .../apache/iotdb/consensus/ratis/UtilsTest.java    |   4 +-
 .../consensus/simple/SimpleConsensusTest.java      |   4 +-
 .../apache/iotdb/it/env/cluster/AbstractEnv.java   |   8 +-
 .../iotdb/it/env/cluster/AbstractNodeWrapper.java  |   6 +-
 .../iotdb/it/env/cluster/ConfigNodeWrapper.java    |  42 ++++---
 .../iotdb/it/env/cluster/DataNodeWrapper.java      |  65 ++++++-----
 .../iotdb/it/env/cluster/MppCommonConfig.java      |   2 +-
 .../it/env/cluster/MppSharedCommonConfig.java      |   6 +-
 .../iotdb/it/env/remote/RemoteCommonConfig.java    |   2 +-
 .../org/apache/iotdb/itbase/env/CommonConfig.java  |   2 +-
 .../confignode/it/IoTDBSnapshotTransferIT.java     |   4 +-
 .../it/cluster/IoTDBClusterNodeErrorStartUpIT.java |   7 +-
 .../it/cluster/IoTDBClusterRestartIT.java          | 117 +++++--------------
 .../it/load/IoTDBConfigNodeSwitchLeaderIT.java     |   2 +-
 .../it/partition/IoTDBPartitionGetterIT.java       |   6 +-
 .../confignode/it/utils/ConfigNodeTestUtils.java   |  27 +----
 .../apache/iotdb/db/it/path/IoTDBFullPathIT.java   |  82 ++++++++++++++
 .../iotdb/db/it/{ => path}/IoTDBQuotedPathIT.java  |   2 +-
 ...ConfigNodeRegionId.java => ConfigRegionId.java} |   6 +-
 .../iotdb/commons/consensus/ConsensusGroupId.java  |   8 +-
 .../commons/utils/ThriftCommonsSerDeUtils.java     |  19 ++++
 .../commons/utils/ThriftCommonsSerDeUtilsTest.java |  32 +++++-
 pom.xml                                            |   2 +-
 .../schemaregion/rocksdb/RSchemaRegion.java        |  12 +-
 .../iotdb/db/auth/ClusterAuthorityFetcher.java     |  14 +--
 .../apache/iotdb/db/client/ConfigNodeClient.java   |  39 ++-----
 .../iotdb/db/client/ConfigNodeClientManager.java   |   8 +-
 .../org/apache/iotdb/db/client/ConfigNodeInfo.java |   8 +-
 .../iotdb/db/client/DataNodeClientPoolFactory.java |  14 +--
 .../org/apache/iotdb/db/conf/IoTDBStartCheck.java  |  22 +++-
 .../execute/task/InnerSpaceCompactionTask.java     |   9 +-
 .../compaction/schedule/CompactionScheduler.java   | 125 ++++++++++++---------
 .../impl/RewriteCrossSpaceCompactionSelector.java  |  42 +++----
 .../impl/SizeTieredCompactionSelector.java         |   2 +-
 .../iotdb/db/engine/storagegroup/DataRegion.java   |   2 +-
 .../engine/storagegroup/TsFileProcessorInfo.java   |  14 +--
 .../storagegroup/TsFileProcessorInfoMetrics.java   |   4 +-
 .../apache/iotdb/db/metadata/MetadataConstant.java |   2 +
 .../metadata/schemaregion/ISchemaRegionParams.java |  22 ++--
 .../metadata/schemaregion/RSchemaRegionLoader.java |  24 +---
 .../db/metadata/schemaregion/SchemaEngine.java     |  72 +++---------
 .../db/metadata/schemaregion/SchemaRegion.java     |  21 ++--
 .../metadata/schemaregion/SchemaRegionLoader.java  | 124 ++++++++++++++++++++
 .../schemaregion/SchemaRegionMemoryImpl.java       |  19 ++--
 .../metadata/schemaregion/SchemaRegionParams.java  |  67 +++++++++++
 .../schemaregion/SchemaRegionSchemaFileImpl.java   |  17 ++-
 .../metadata/template/ClusterTemplateManager.java  |  16 +--
 .../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java  |   2 +-
 .../mpp/plan/analyze/ClusterPartitionFetcher.java  |  18 +--
 .../db/mpp/plan/analyze/cache/PartitionCache.java  |  10 +-
 .../config/executor/ClusterConfigTaskExecutor.java |  99 ++++++++--------
 .../iotdb/db/mpp/plan/parser/ASTVisitor.java       |  75 ++++++-------
 .../db/mpp/plan/planner/OperatorTreeGenerator.java |  17 ++-
 .../iotdb/db/rescon/TsFileResourceManager.java     |   5 +-
 .../java/org/apache/iotdb/db/service/DataNode.java |  19 ++--
 .../db/service/DataNodeServerCommandLine.java      |   6 +-
 .../apache/iotdb/db/service/IoTDBShutdownHook.java |   2 +-
 .../iotdb/db/service/RegionMigrateService.java     |   2 +-
 .../db/sync/common/ClusterSyncInfoFetcher.java     |  12 +-
 .../db/trigger/executor/TriggerFireVisitor.java    |   8 +-
 .../trigger/service/TriggerInformationUpdater.java |   8 +-
 .../inner/InnerCompactionSchedulerTest.java        |   6 +-
 .../iotdb/db/rescon/ResourceManagerTest.java       |  56 ++++-----
 thrift-commons/src/main/thrift/common.thrift       |   2 +-
 .../src/main/thrift/confignode.thrift              |  21 +---
 82 files changed, 1035 insertions(+), 881 deletions(-)