This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch support_table_model_redirect
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e22f3567970 fix remove broken connection
add 697871705ec Refactor: Removed the useless Ser/de logic in configNode
read plans (#13577)
add 5de8dc7a4db IoTConsensusV2: Introduce IoTConsensusV2 and corresponding
mode option (#13440)
add acda1a0f092 Make log dispatcher stop in parallel #13588
add cb4befcbd45 fix bug (#13590)
add 24d1191a8e7 Fix potential NPE when write FileTimeIndexCache (#13583)
add 197965e9ae9 Skip the file timestamp check of tsfiles generated by
repair task (#13581)
add 737c4ccea98 Fix print error log when dir is not exist (#13591)
add 5b22e7b010b Handle commit failure of table procedures
add ed8f61cb38d Update tsfile version to 1.2.0-240924-SNAPSHOT (#13603)
add fa32859c6aa Merge branch 'master' of github.com:apache/iotdb into
support_table_model_redirect
No new revisions were added by this update.
Summary of changes:
.../iotdb/it/env/cluster/ClusterConstant.java | 4 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 18 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 5 +-
.../consensus/request/ConfigPhysicalPlan.java | 170 +-------
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/ConfigPhysicalPlanVisitor.java | 2 +-
...PipePlanV2.java => ConfigPhysicalReadPlan.java} | 14 +-
.../read/ainode/GetAINodeConfigurationPlan.java | 31 +-
.../request/read/auth/AuthorReadPlan.java | 143 ++++++
.../consensus/request/read/cq/ShowCQPlan.java | 14 +-
.../request/read/database/CountDatabasePlan.java | 51 +--
.../request/read/database/GetDatabasePlan.java | 6 +-
.../datanode/GetDataNodeConfigurationPlan.java | 30 +-
.../read/function/GetFunctionTablePlan.java | 18 +-
.../request/read/function/GetUDFJarPlan.java | 42 +-
.../request/read/model/GetModelInfoPlan.java | 32 +-
.../request/read/model/ShowModelPlan.java | 34 +-
.../read/partition/CountTimeSlotListPlan.java | 49 +--
.../read/partition/GetDataPartitionPlan.java | 66 +--
.../read/partition/GetNodePathsPartitionPlan.java | 33 +-
.../partition/GetOrCreateDataPartitionPlan.java | 10 +-
.../partition/GetOrCreateSchemaPartitionPlan.java | 3 +-
.../read/partition/GetSchemaPartitionPlan.java | 58 +--
.../read/partition/GetSeriesSlotListPlan.java | 36 +-
.../read/partition/GetTimeSlotListPlan.java | 49 +--
.../read/pipe/plugin/GetPipePluginJarPlan.java | 35 +-
.../read/pipe/plugin/GetPipePluginTablePlan.java | 18 +-
.../request/read/pipe/task/ShowPipePlanV2.java | 18 +-
.../request/read/region/GetRegionIdPlan.java | 49 +--
.../request/read/region/GetRegionInfoListPlan.java | 47 +-
.../read/subscription/ShowSubscriptionPlan.java | 18 +-
.../request/read/subscription/ShowTopicPlan.java | 18 +-
.../FetchTablePlan.java} | 20 +-
.../request/read/table/ShowTablePlan.java | 27 +-
.../read/template/CheckTemplateSettablePlan.java | 33 +-
.../read/template/GetAllSchemaTemplatePlan.java | 16 +-
.../read/template/GetAllTemplateSetInfoPlan.java | 16 +-
.../read/template/GetPathsSetTemplatePlan.java | 33 +-
.../read/template/GetSchemaTemplatePlan.java | 32 +-
.../read/template/GetTemplateSetInfoPlan.java | 37 +-
.../read/trigger/GetTransferringTriggersPlan.java | 18 +-
.../request/read/trigger/GetTriggerJarPlan.java | 42 +-
.../read/trigger/GetTriggerLocationPlan.java | 38 +-
.../request/read/trigger/GetTriggerTablePlan.java | 38 +-
.../consensus/request/read/ttl/ShowTTLPlan.java | 19 +-
.../request/{ => write}/auth/AuthorPlan.java | 99 +----
.../consensus/request/write/cq/ShowCQPlan.java | 45 --
.../write/partition/RemoveRegionLocationPlan.java | 5 -
.../request/write/sync/ShowPipePlanV1.java | 59 ---
.../{ShowTableResp.java => FetchTableResp.java} | 21 +-
.../statemachine/ConfigRegionStateMachine.java | 22 +-
.../iotdb/confignode/manager/ConfigManager.java | 36 +-
.../apache/iotdb/confignode/manager/IManager.java | 11 +-
.../iotdb/confignode/manager/ModelManager.java | 10 +-
.../confignode/manager/PermissionManager.java | 9 +-
.../iotdb/confignode/manager/ProcedureManager.java | 18 +-
.../manager/consensus/ConsensusManager.java | 3 +-
.../iotdb/confignode/manager/cq/CQManager.java | 2 +-
.../manager/load/balancer/RouteBalancer.java | 3 -
.../manager/partition/PartitionManager.java | 16 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 2 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 2 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 2 +-
.../manager/schema/ClusterSchemaManager.java | 16 +
.../iotdb/confignode/persistence/AuthorInfo.java | 53 +--
.../persistence/executor/ConfigPlanExecutor.java | 17 +-
.../schema/CNPhysicalPlanGenerator.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 23 +
.../confignode/persistence/schema/ConfigMTree.java | 17 +
.../impl/schema/table/AddTableColumnProcedure.java | 1 -
.../impl/schema/table/CreateTableProcedure.java | 1 -
.../schema/table/SetTablePropertiesProcedure.java | 1 -
.../impl/sync/AuthOperationProcedure.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 14 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 482 +--------------------
...eConfigPhysicalPlanPatternParseVisitorTest.java | 2 +-
.../confignode/persistence/AuthorInfoTest.java | 82 ++--
.../persistence/CNPhysicalPlanGeneratorTest.java | 2 +-
.../ConfigRegionListeningQueueTest.java | 2 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 2 +-
.../impl/sync/AuthOperationProcedureTest.java | 29 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 23 +-
.../consensus/config/PipeConsensusConfig.java | 26 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 4 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 11 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 50 ++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 32 +-
.../db/consensus/DataRegionConsensusImpl.java | 4 +-
.../agent/receiver/PipeDataNodeReceiverAgent.java | 2 +-
.../pipeconsensus/PipeConsensusAsyncConnector.java | 4 +-
.../pipeconsensus/PipeConsensusReceiver.java | 13 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 9 +
.../config/executor/ClusterConfigTaskExecutor.java | 22 +-
.../config/executor/IConfigTaskExecutor.java | 4 +
.../plan/planner/plan/node/write/InsertNode.java | 1 -
.../fetcher/TableHeaderSchemaValidator.java | 60 ++-
.../db/schemaengine/table/DataNodeTableCache.java | 217 ++++++++--
.../java/org/apache/iotdb/db/service/DataNode.java | 3 +-
.../iotdb/db/storageengine/StorageEngine.java | 3 -
.../db/storageengine/dataregion/DataRegion.java | 10 +-
.../execute/task/AbstractCompactionTask.java | 2 +-
.../task/InsertionCrossSpaceCompactionTask.java | 2 +
.../task/RepairUnsortedFileCompactionTask.java | 4 +
.../compaction/repair/RepairDataFileScanUtil.java | 10 +-
.../repair/RepairTimePartitionScanTask.java | 2 +-
.../dataregion/tsfile/TsFileResource.java | 2 +-
.../FileTimeIndexCacheWriter.java | 8 +-
.../storageengine/dataregion/wal/WALManager.java | 18 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 7 +-
.../conf/iotdb-system.properties.template | 25 +-
.../assembly/resources/sbin/destroy-datanode.bat | 12 +-
.../assembly/resources/sbin/destroy-datanode.sh | 4 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 4 +-
.../schema/table/TsTableInternalRPCUtil.java | 94 +++-
.../org/apache/iotdb/commons/utils/PathUtils.java | 7 +
.../src/main/thrift/confignode.thrift | 7 +
pom.xml | 2 +-
118 files changed, 1141 insertions(+), 2174 deletions(-)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{pipe/task/ShowPipePlanV2.java
=> ConfigPhysicalReadPlan.java} (72%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/auth/AuthorReadPlan.java
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeSinkException.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/cq/ShowCQPlan.java
(70%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{partition/GetOrCreateSchemaPartitionPlan.java
=> table/FetchTablePlan.java} (63%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{
=> write}/auth/AuthorPlan.java (67%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/ShowCQPlan.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/ShowPipePlanV1.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/table/{ShowTableResp.java
=> FetchTableResp.java} (61%)
