This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch test_wal_sync_pr
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0cf441e684 add write status check for MultiLeader
add 25d442ad83 [IOTDB-3159] Granting the user privileges to create_user
does not require adding a path (#6485)
add c5dd57e66a Add cluster setup command in UserGuide (#6502)
add c0f46caae9 Add configuration (#6503)
add 7b9f1da03d Add 0.14.0-preview1 release note (#6505)
add 0df692b41e update quickstart (#6507)
add 2fcc203c0a fix cross compaction logs (#6504)
add 7909228dce [IOTDB-3666] Rename XXReq in ConfigNode to XXPlan (#6490)
add 811a267795 [IOTDB-3525] Apply Producer-Consumer pattern to compaction
submission (#6378)
add 48bf156d80 Merge branch 'master' into test_wal_sync_pr
add 17192cd3ad downgrade log level for debug
No new revisions were added by this update.
Summary of changes:
RELEASE_NOTES.md | 132 ++++++++
.../confignode/client/AsyncDataNodeClientPool.java | 10 +-
...{ConfigRequest.java => ConfigPhysicalPlan.java} | 134 ++++----
...equestType.java => ConfigPhysicalPlanType.java} | 2 +-
.../auth/{AuthorReq.java => AuthorPlan.java} | 60 ++--
...ageGroupReq.java => CountStorageGroupPlan.java} | 18 +-
...taNodeInfoReq.java => GetDataNodeInfoPlan.java} | 16 +-
...PartitionReq.java => GetDataPartitionPlan.java} | 16 +-
...tionReq.java => GetNodePathsPartitionPlan.java} | 12 +-
...nReq.java => GetOrCreateDataPartitionPlan.java} | 8 +-
...eq.java => GetOrCreateSchemaPartitionPlan.java} | 8 +-
...InfoListReq.java => GetRegionInfoListPlan.java} | 14 +-
...rtitionReq.java => GetSchemaPartitionPlan.java} | 16 +-
...orageGroupReq.java => GetStorageGroupPlan.java} | 12 +-
...Req.java => AdjustMaxRegionGroupCountPlan.java} | 14 +-
...ConfigNodeReq.java => ApplyConfigNodePlan.java} | 16 +-
...titionReq.java => CreateDataPartitionPlan.java} | 14 +-
...ateFunctionReq.java => CreateFunctionPlan.java} | 14 +-
...reateRegionsReq.java => CreateRegionsPlan.java} | 14 +-
...tionReq.java => CreateSchemaPartitionPlan.java} | 14 +-
...eProcedureReq.java => DeleteProcedurePlan.java} | 14 +-
...eleteRegionsReq.java => DeleteRegionsPlan.java} | 14 +-
...geGroupReq.java => DeleteStorageGroupPlan.java} | 16 +-
...{DropFunctionReq.java => DropFunctionPlan.java} | 14 +-
...roupReq.java => PreDeleteStorageGroupPlan.java} | 14 +-
...rDataNodeReq.java => RegisterDataNodePlan.java} | 16 +-
...onfigNodeReq.java => RemoveConfigNodePlan.java} | 16 +-
...rReq.java => SetDataReplicationFactorPlan.java} | 14 +-
...eq.java => SetSchemaReplicationFactorPlan.java} | 14 +-
...orageGroupReq.java => SetStorageGroupPlan.java} | 16 +-
.../write/{SetTTLReq.java => SetTTLPlan.java} | 16 +-
...lReq.java => SetTimePartitionIntervalPlan.java} | 14 +-
...eProcedureReq.java => UpdateProcedurePlan.java} | 14 +-
.../statemachine/PartitionRegionStateMachine.java | 28 +-
.../physical/UnknownPhysicalPlanTypeException.java | 4 +-
.../confignode/manager/ClusterSchemaManager.java | 59 ++--
.../iotdb/confignode/manager/ConfigManager.java | 118 +++----
.../iotdb/confignode/manager/ConsensusManager.java | 22 +-
.../apache/iotdb/confignode/manager/IManager.java | 58 ++--
.../iotdb/confignode/manager/NodeManager.java | 38 +--
.../iotdb/confignode/manager/PartitionManager.java | 42 +--
.../confignode/manager/PermissionManager.java | 24 +-
.../iotdb/confignode/manager/UDFManager.java | 8 +-
.../iotdb/confignode/manager/load/LoadManager.java | 10 +-
.../manager/load/balancer/RegionBalancer.java | 14 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 30 +-
.../confignode/persistence/ClusterSchemaInfo.java | 68 ++--
.../iotdb/confignode/persistence/NodeInfo.java | 44 +--
.../confignode/persistence/ProcedureInfo.java | 12 +-
.../iotdb/confignode/persistence/UDFInfo.java | 8 +-
...equestExecutor.java => ConfigPlanExecutor.java} | 134 ++++----
.../persistence/partition/PartitionInfo.java | 82 ++---
.../partition/StorageGroupPartitionTable.java | 8 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 15 +-
.../impl/DeleteStorageGroupProcedure.java | 6 +-
.../procedure/store/ConfigProcedureStore.java | 16 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 83 ++---
...eTest.java => ConfigPhysicalPlanSerDeTest.java} | 367 +++++++++++----------
.../confignode/persistence/AuthorInfoTest.java | 180 +++++-----
.../persistence/ClusterSchemaInfoTest.java | 10 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 14 +-
.../confignode/persistence/PartitionInfoTest.java | 52 +--
.../multileader/MultiLeaderServerImpl.java | 14 +-
.../multileader/logdispatcher/LogDispatcher.java | 16 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 65 +++-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 64 +++-
.../it/{IoTDBExampleIT.java => IoTDBAuthIT.java} | 74 ++++-
.../integration/IoTDBSizeTieredCompactionIT.java | 22 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2 +-
.../db/engine/compaction/CompactionScheduler.java | 6 +-
.../engine/compaction/CompactionTaskManager.java | 229 ++++++-------
.../db/engine/compaction/CompactionWorker.java | 117 +++++++
.../compaction/cross/CrossSpaceCompactionTask.java | 43 ++-
.../rewrite/CrossSpaceCompactionResource.java | 8 -
.../RewriteCrossSpaceCompactionSelector.java | 4 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 84 +++--
.../compaction/performer/ICompactionPerformer.java | 3 +
.../impl/ReadChunkCompactionPerformer.java | 9 +-
.../impl/ReadPointCompactionPerformer.java | 9 +-
.../compaction/task/AbstractCompactionTask.java | 62 ++--
.../compaction/task/CompactionTaskSummary.java | 51 ++-
.../iotdb/db/engine/storagegroup/DataRegion.java | 1 -
.../db/engine/storagegroup/TsFileManager.java | 14 +-
.../db/engine/storagegroup/TsFileResource.java | 3 -
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 28 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 1 -
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 7 +-
.../engine/compaction/CompactionSchedulerTest.java | 95 +++---
.../compaction/CompactionTaskComparatorTest.java | 10 +-
.../compaction/CompactionTaskManagerTest.java | 115 ++-----
.../ReadPointCompactionPerformerTest.java | 137 ++++++--
.../cross/CrossSpaceCompactionExceptionTest.java | 27 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 6 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 37 ++-
.../cross/RewriteCrossSpaceCompactionTest.java | 8 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 6 +-
.../compaction/inner/InnerCompactionLogTest.java | 1 -
.../inner/InnerCompactionMoreDataTest.java | 5 +-
.../inner/InnerCompactionSchedulerTest.java | 4 -
.../compaction/inner/InnerSeqCompactionTest.java | 17 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 30 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 10 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 30 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 47 ++-
.../inner/ReadChunkCompactionPerformerOldTest.java | 7 +-
.../SizeTieredCompactionRecoverTest.java | 70 ++--
.../SizeTieredCompactionRecoverCompatibleTest.java | 18 +-
.../recover/SizeTieredCompactionRecoverTest.java | 38 ++-
.../db/engine/storagegroup/DataRegionTest.java | 6 +-
.../storagegroup/StorageGroupProcessorTest.java | 6 +-
site/src/main/.vuepress/config.js | 8 +-
111 files changed, 2353 insertions(+), 1611 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{ConfigRequest.java
=> ConfigPhysicalPlan.java} (72%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{ConfigRequestType.java
=> ConfigPhysicalPlanType.java} (97%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/auth/{AuthorReq.java
=> AuthorPlan.java} (77%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{CountStorageGroupReq.java
=> CountStorageGroupPlan.java} (79%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetDataNodeInfoReq.java
=> GetDataNodeInfoPlan.java} (78%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetDataPartitionReq.java
=> GetDataPartitionPlan.java} (92%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetNodePathsPartitionReq.java
=> GetNodePathsPartitionPlan.java} (84%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetOrCreateSchemaPartitionReq.java
=> GetOrCreateDataPartitionPlan.java} (77%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetOrCreateDataPartitionReq.java
=> GetOrCreateSchemaPartitionPlan.java} (77%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetRegionInfoListReq.java
=> GetRegionInfoListPlan.java} (80%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetSchemaPartitionReq.java
=> GetSchemaPartitionPlan.java} (88%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetStorageGroupReq.java
=> GetStorageGroupPlan.java} (70%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{AdjustMaxRegionGroupCountReq.java
=> AdjustMaxRegionGroupCountPlan.java} (85%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{ApplyConfigNodeReq.java
=> ApplyConfigNodePlan.java} (80%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{CreateDataPartitionReq.java
=> CreateDataPartitionPlan.java} (87%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{CreateFunctionReq.java
=> CreateFunctionPlan.java} (83%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{CreateRegionsReq.java
=> CreateRegionsPlan.java} (88%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{CreateSchemaPartitionReq.java
=> CreateSchemaPartitionPlan.java} (87%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DeleteProcedureReq.java
=> DeleteProcedurePlan.java} (79%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DeleteRegionsReq.java
=> DeleteRegionsPlan.java} (88%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DeleteStorageGroupReq.java
=> DeleteStorageGroupPlan.java} (77%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DropFunctionReq.java
=> DropFunctionPlan.java} (79%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{PreDeleteStorageGroupReq.java
=> PreDeleteStorageGroupPlan.java} (82%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{RegisterDataNodeReq.java
=> RegisterDataNodePlan.java} (78%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{RemoveConfigNodeReq.java
=> RemoveConfigNodePlan.java} (80%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{SetDataReplicationFactorReq.java
=> SetDataReplicationFactorPlan.java} (81%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{SetSchemaReplicationFactorReq.java
=> SetSchemaReplicationFactorPlan.java} (81%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{SetStorageGroupReq.java
=> SetStorageGroupPlan.java} (79%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{SetTTLReq.java
=> SetTTLPlan.java} (81%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{SetTimePartitionIntervalReq.java
=> SetTimePartitionIntervalPlan.java} (81%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{UpdateProcedureReq.java
=> UpdateProcedurePlan.java} (82%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/{ConfigRequestExecutor.java
=> ConfigPlanExecutor.java} (81%)
rename
confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/{ConfigRequestSerDeTest.java
=> ConfigPhysicalPlanSerDeTest.java} (60%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBExampleIT.java =>
IoTDBAuthIT.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionWorker.java
