This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch 1c1d_dockertest
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from dc992af5e4 Update start-1c1d.sh
new 19279e372c use 1c1d docker to run python and influxdb protocal IT
add d66d6445ed [IOTDB-4714] Rename TPipeInfo to TCreatePipeReq (#7692)
add 631fad8860 Fix schema region recover bug (#7696)
add 2fea01176c Bump flink.version from 1.14.5 to 1.14.6 (#7614)
add ca7b2b8311 [IOTDB-4641] New Standalone Sync Receiver TsFile Loader
Implement (#7610)
add f9f9721969 [IOTDB-3562] Support Deactivate Template in cluster (#7674)
add 6101e132d6 [IOTDB-4293] BufferedPipeDataQueue supports discontinuous
serialNumber (#7664)
add 083b241b84 Integrate dockerfile from rel/0.12, rel/0.13 (#7701)
add bcc9c3be79 [IOTDB-4712]Add size limit of trigger jar when create
Trigger on ConfigNode (#7684)
new 817c655337 Merge branch 'master' of https://github.com/apache/iotdb
into 1c1d_dockertest
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/client-python.yml | 2 +-
.github/workflows/influxdb-protocol.yml | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
client-py/tests/test_dataframe.py | 4 +-
.../confignode/client/DataNodeRequestType.java | 8 +-
.../client/async/AsyncDataNodeClientPool.java | 38 +-
.../client/async/handlers/AsyncClientHandler.java | 9 +-
...RPCHandler.java => DeleteSchemaRPCHandler.java} | 6 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 3 +-
.../GetTemplateSetInfoPlan.java} | 38 +-
.../write/procedure/UpdateProcedurePlan.java | 13 +
...plateInfoResp.java => TemplateSetInfoResp.java} | 18 +-
.../confignode/manager/ClusterSchemaManager.java | 7 +
.../iotdb/confignode/manager/ConfigManager.java | 53 ++-
.../apache/iotdb/confignode/manager/IManager.java | 10 +-
.../iotdb/confignode/manager/ProcedureManager.java | 99 ++++-
.../iotdb/confignode/manager/TriggerManager.java | 2 +
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../persistence/schema/ClusterSchemaInfo.java | 48 ++
.../persistence/schema/TemplateTable.java | 16 +
.../impl/schema/DataNodeRegionGroupUtil.java | 81 ++++
.../procedure/impl/schema/DataNodeRegionTask.java | 195 +++++++++
.../impl/schema/DeactivateTemplateProcedure.java | 487 +++++++++++++++++++++
.../DeleteStorageGroupProcedure.java | 5 +-
.../DeleteTimeSeriesProcedure.java | 333 +++++---------
.../procedure/impl/sync/CreatePipeProcedure.java | 6 +-
.../DeactivateTemplateState.java} | 6 +-
.../{ => schema}/DeleteStorageGroupState.java | 2 +-
.../state/{ => schema}/DeleteTimeSeriesState.java | 2 +-
.../procedure/store/ProcedureFactory.java | 13 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 10 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 4 +-
.../confignode/persistence/TriggerInfoTest.java | 3 +
.../procedure/impl/CreateTriggerProcedureTest.java | 3 +
.../impl/DeactivateTemplateProcedureTest.java | 89 ++++
.../impl/DeleteStorageGroupProcedureTest.java | 2 +-
.../impl/DeleteTimeSeriesProcedureTest.java | 2 +-
.../procedure/impl/OperatePipeProcedureTest.java | 8 +-
docker/src/main/Dockerfile-0.10.0 | 39 --
docker/src/main/Dockerfile-0.11.0 | 39 --
docker/src/main/Dockerfile-0.11.1 | 39 --
docker/src/main/Dockerfile-0.11.2 | 41 --
docker/src/main/Dockerfile-0.11.3 | 41 --
docker/src/main/Dockerfile-0.12.1-cluster | 53 ---
...le-0.12.0-cluster => Dockerfile-0.12.6-cluster} | 10 +-
...le-0.12.2-grafana => Dockerfile-0.12.6-grafana} | 10 +-
...ckerfile-0.12.0-node => Dockerfile-0.12.6-node} | 10 +-
...le-0.12.2-cluster => Dockerfile-0.13.0-cluster} | 10 +-
...grafana => Dockerfile-0.13.3-grafana-connector} | 20 +-
...ckerfile-0.12.1-node => Dockerfile-0.13.3-node} | 10 +-
...-node => Dockerfile-0.13.3-node-multi-platform} | 12 +-
docker/src/main/Dockerfile-0.9.0 | 41 --
.../{Dockerfile-1c1d => Dockerfile-1c1d-influxdb} | 3 +-
docs/UserGuide/Operate-Metadata/Template.md | 38 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 40 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 231 ++++++++++
.../apache/iotdb/db/it/sync/SyncTransportTest.java | 323 ++++++++++++++
.../apache/iotdb/commons/conf/IoTDBConstant.java | 3 +
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +
.../iotdb/commons/trigger/TriggerInformation.java | 3 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 19 -
pom.xml | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 23 +-
.../schemaregion/rocksdb/mnode/REntityMNode.java | 20 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 21 +-
.../iotdb/db/metadata/mnode/EntityMNode.java | 38 ++
.../iotdb/db/metadata/mnode/IEntityMNode.java | 8 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 8 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 39 ++
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 102 +++--
.../db/metadata/mtree/traverser/Traverser.java | 19 +-
.../traverser/collector/MeasurementCollector.java | 3 +-
.../plan/schemaregion/SchemaRegionPlanType.java | 6 +-
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 17 +
.../impl/ActivateTemplateInClusterPlanImpl.java | 8 +-
...anImpl.java => DeactivateTemplatePlanImpl.java} | 21 +-
...mpl.java => PreDeactivateTemplatePlanImpl.java} | 21 +-
... => RollbackPreDeactivateTemplatePlanImpl.java} | 21 +-
.../impl/SchemaRegionPlanDeserializer.java | 43 ++
.../schemaregion/impl/SchemaRegionPlanFactory.java | 6 +
.../impl/SchemaRegionPlanSerializer.java | 51 +++
.../impl/SchemaRegionPlanTxtSerializer.java | 35 ++
.../write/IActivateTemplateInClusterPlan.java | 4 +-
...eriesPlan.java => IDeactivateTemplatePlan.java} | 11 +-
...esPlan.java => IPreDeactivateTemplatePlan.java} | 11 +-
...ava => IRollbackPreDeactivateTemplatePlan.java} | 11 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 15 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 124 +++++-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 25 +-
.../iotdb/db/metadata/template/Template.java | 5 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 38 ++
.../schema/PathsUsingTemplateScanOperator.java | 21 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 12 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 22 +-
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 86 +++-
.../config/executor/IConfigTaskExecutor.java | 4 +
.../executor/StandaloneConfigTaskExecutor.java | 12 +
...Task.java => DeactivateSchemaTemplateTask.java} | 15 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 25 +-
.../db/mpp/plan/parser/StatementGenerator.java | 4 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 7 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 4 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 2 +-
.../plan/planner/distribution/SourceRewriter.java | 88 +++-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 14 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 15 +
.../metedata/read/PathsUsingTemplateScanNode.java | 36 +-
.../node/metedata/read/SchemaQueryScanNode.java | 10 +
.../metedata/write/DeactivateTemplateNode.java | 128 ++++++
.../metedata/write/PreDeactivateTemplateNode.java | 128 ++++++
.../write/RollbackPreDeactivateTemplateNode.java | 130 ++++++
.../db/mpp/plan/statement/StatementVisitor.java | 6 +
.../plan/statement/crud/LoadTsFileStatement.java | 4 +
...ement.java => DeactivateTemplateStatement.java} | 40 +-
.../template/ShowPathsUsingTemplateStatement.java | 22 +-
.../sys/ActivateTemplateInClusterPlan.java | 8 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 157 ++++++-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 70 +--
.../db/sync/receiver/load/DeletionLoader.java | 52 ++-
.../iotdb/db/sync/receiver/load/ILoader.java | 20 +
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 58 ++-
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 4 +-
.../plan/SchemaRegionPlanCompatibilityTest.java | 22 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 6 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 95 ++++
.../iotdb/db/sync/transport/SyncTransportTest.java | 357 ---------------
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +-
.../src/main/thrift/confignode.thrift | 11 +-
thrift/src/main/thrift/datanode.thrift | 41 +-
133 files changed, 3846 insertions(+), 1344 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{DeleteTimeSeriesRPCHandler.java
=> DeleteSchemaRPCHandler.java} (95%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetTriggerJarPlan.java
=> template/GetTemplateSetInfoPlan.java} (59%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{TemplateInfoResp.java
=> TemplateSetInfoResp.java} (70%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeRegionGroupUtil.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeRegionTask.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/{statemachine
=> schema}/DeleteStorageGroupProcedure.java (97%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/{statemachine
=> schema}/DeleteTimeSeriesProcedure.java (60%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{DeleteTimeSeriesState.java
=> schema/DeactivateTemplateState.java} (88%)
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{
=> schema}/DeleteStorageGroupState.java (93%)
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{
=> schema}/DeleteTimeSeriesState.java (94%)
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/DeactivateTemplateProcedureTest.java
delete mode 100644 docker/src/main/Dockerfile-0.10.0
delete mode 100644 docker/src/main/Dockerfile-0.11.0
delete mode 100644 docker/src/main/Dockerfile-0.11.1
delete mode 100644 docker/src/main/Dockerfile-0.11.2
delete mode 100644 docker/src/main/Dockerfile-0.11.3
delete mode 100644 docker/src/main/Dockerfile-0.12.1-cluster
rename docker/src/main/{Dockerfile-0.12.0-cluster =>
Dockerfile-0.12.6-cluster} (85%)
copy docker/src/main/{Dockerfile-0.12.2-grafana => Dockerfile-0.12.6-grafana}
(83%)
rename docker/src/main/{Dockerfile-0.12.0-node => Dockerfile-0.12.6-node} (83%)
rename docker/src/main/{Dockerfile-0.12.2-cluster =>
Dockerfile-0.13.0-cluster} (85%)
rename docker/src/main/{Dockerfile-0.12.2-grafana =>
Dockerfile-0.13.3-grafana-connector} (66%)
rename docker/src/main/{Dockerfile-0.12.1-node => Dockerfile-0.13.3-node} (83%)
rename docker/src/main/{Dockerfile-0.12.2-node =>
Dockerfile-0.13.3-node-multi-platform} (80%)
delete mode 100644 docker/src/main/Dockerfile-0.9.0
copy docker/src/main/{Dockerfile-1c1d => Dockerfile-1c1d-influxdb} (92%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBDeactivateTemplateIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/sync/SyncTransportTest.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{RollbackPreDeleteTimeSeriesPlanImpl.java
=> DeactivateTemplatePlanImpl.java} (66%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{PreDeleteTimeSeriesPlanImpl.java
=> PreDeactivateTemplatePlanImpl.java} (70%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{RollbackPreDeleteTimeSeriesPlanImpl.java
=> RollbackPreDeactivateTemplatePlanImpl.java} (69%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/{IDeleteTimeSeriesPlan.java
=> IDeactivateTemplatePlan.java} (80%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/{IDeleteTimeSeriesPlan.java
=> IPreDeactivateTemplatePlan.java} (79%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/{IDeleteTimeSeriesPlan.java
=> IRollbackPreDeactivateTemplatePlan.java} (78%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/template/{SetSchemaTemplateTask.java
=> DeactivateSchemaTemplateTask.java} (76%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/DeactivateTemplateNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/PreDeactivateTemplateNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/RollbackPreDeactivateTemplateNode.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/{SetSchemaTemplateStatement.java
=> DeactivateTemplateStatement.java} (64%)
delete mode 100644
server/src/test/java/org/apache/iotdb/db/sync/transport/SyncTransportTest.java
