You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/10/24 06:44:42 UTC
[iotdb] branch 1c1d_dockertest updated (dc992af5e4 -> 817c655337)
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
[iotdb] 01/02: use 1c1d docker to run python and influxdb protocal IT
Posted by ha...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch 1c1d_dockertest
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 19279e372c5d2a44a6e2f2ac8f24e1545b547398
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Oct 24 14:41:27 2022 +0800
use 1c1d docker to run python and influxdb protocal IT
---
.github/workflows/client-python.yml | 2 +-
.github/workflows/influxdb-protocol.yml | 2 +-
client-py/tests/test_dataframe.py | 4 +--
docker/src/main/Dockerfile-1c1d-influxdb | 57 ++++++++++++++++++++++++++++++++
4 files changed, 61 insertions(+), 4 deletions(-)
diff --git a/.github/workflows/client-python.yml b/.github/workflows/client-python.yml
index c92cd9f4ae..234cef50c9 100644
--- a/.github/workflows/client-python.yml
+++ b/.github/workflows/client-python.yml
@@ -5,7 +5,7 @@ name: Python Client
on:
push:
branches:
- - 1c1d_dockertest
+ - master
- 'rel/*'
- "new_*"
paths-ignore:
diff --git a/.github/workflows/influxdb-protocol.yml b/.github/workflows/influxdb-protocol.yml
index 7aac7da02c..9a111fd9dc 100644
--- a/.github/workflows/influxdb-protocol.yml
+++ b/.github/workflows/influxdb-protocol.yml
@@ -61,7 +61,7 @@ jobs:
- name: Build Docker Image
run: |
- docker build . -f docker/src/main/Dockerfile-single-influxdb -t "apache/iotdb:influxdb-protocol-on"
+ docker build . -f docker/src/main/Dockerfile-1c1d-influxdb -t "apache/iotdb:influxdb-protocol-on"
docker images
- name: IT Test
diff --git a/client-py/tests/test_dataframe.py b/client-py/tests/test_dataframe.py
index c7cce58ea5..f4f97a0b98 100644
--- a/client-py/tests/test_dataframe.py
+++ b/client-py/tests/test_dataframe.py
@@ -78,8 +78,8 @@ def test_non_time_query():
"FLOAT",
"GORILLA",
"SNAPPY",
- None,
- None,
+ "null",
+ "null",
]
],
)
diff --git a/docker/src/main/Dockerfile-1c1d-influxdb b/docker/src/main/Dockerfile-1c1d-influxdb
new file mode 100644
index 0000000000..9488efbdc0
--- /dev/null
+++ b/docker/src/main/Dockerfile-1c1d-influxdb
@@ -0,0 +1,57 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+
+# docker build context is the root path of the repository
+
+FROM openjdk:11-jre-slim
+
+ADD distribution/target/apache-iotdb-*-all-bin.zip /
+ADD docker/src/main/DockerCompose/start-1c1d.sh /
+
+RUN apt update \
+ && apt install lsof dos2unix procps unzip -y \
+ && unzip /apache-iotdb-*-bin.zip -d / \
+ && rm /apache-iotdb-*-bin.zip \
+ && mv /apache-iotdb-* /iotdb \
+ && mv /start-1c1d.sh /iotdb/sbin \
+ && sed -i '/^# enable_influxdb_rpc_service=false/a enable_influxdb_rpc_service=true' /iotdb/sbin/../conf/iotdb-datanode.properties \
+ && apt remove unzip -y \
+ && apt autoremove -y \
+ && apt purge --auto-remove -y \
+ && apt clean -y
+RUN dos2unix /iotdb/sbin/start-1c1d.sh
+RUN dos2unix /iotdb/sbin/start-confignode.sh
+RUN dos2unix /iotdb/sbin/../conf/confignode-env.sh
+RUN dos2unix /iotdb/sbin/start-datanode.sh
+RUN dos2unix /iotdb/sbin/../conf/datanode-env.sh
+EXPOSE 6667
+EXPOSE 31999
+EXPOSE 5555
+EXPOSE 8086
+EXPOSE 8181
+EXPOSE 22278
+EXPOSE 22277
+EXPOSE 8777
+EXPOSE 9003
+EXPOSE 40010
+EXPOSE 50010
+VOLUME /iotdb/data
+VOLUME /iotdb/logs
+ENV PATH="/iotdb/sbin/:/iotdb/tools/:${PATH}"
+ENTRYPOINT ["/iotdb/sbin/start-1c1d.sh"]
[iotdb] 02/02: Merge branch 'master' of https://github.com/apache/iotdb into 1c1d_dockertest
Posted by ha...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch 1c1d_dockertest
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 817c655337ddce984f514777d524a0075131ae91
Merge: 19279e372c bcc9c3be79
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Oct 24 14:44:08 2022 +0800
Merge branch 'master' of https://github.com/apache/iotdb into 1c1d_dockertest
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 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 +-
.../template/GetTemplateSetInfoPlan.java} | 54 +--
.../write/procedure/UpdateProcedurePlan.java | 13 +
.../consensus/response/TemplateSetInfoResp.java | 41 +-
.../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.2-cluster | 53 ---
...le-0.12.1-cluster => Dockerfile-0.12.6-cluster} | 10 +-
...le-0.12.2-grafana => Dockerfile-0.12.6-grafana} | 10 +-
...ckerfile-0.12.2-node => Dockerfile-0.12.6-node} | 10 +-
...le-0.12.0-cluster => Dockerfile-0.13.0-cluster} | 10 +-
...grafana => Dockerfile-0.13.3-grafana-connector} | 20 +-
...ckerfile-0.12.0-node => Dockerfile-0.13.3-node} | 10 +-
...-node => Dockerfile-0.13.3-node-multi-platform} | 12 +-
docker/src/main/Dockerfile-0.9.0 | 41 --
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 +-
.../impl/DeactivateTemplatePlanImpl.java} | 34 +-
.../impl/PreDeactivateTemplatePlanImpl.java} | 34 +-
.../RollbackPreDeactivateTemplatePlanImpl.java} | 34 +-
.../impl/SchemaRegionPlanDeserializer.java | 43 ++
.../schemaregion/impl/SchemaRegionPlanFactory.java | 6 +
.../impl/SchemaRegionPlanSerializer.java | 51 +++
.../impl/SchemaRegionPlanTxtSerializer.java | 35 ++
.../write/IActivateTemplateInClusterPlan.java | 4 +-
...usterPlan.java => IDeactivateTemplatePlan.java} | 29 +-
...erPlan.java => IPreDeactivateTemplatePlan.java} | 29 +-
...ava => IRollbackPreDeactivateTemplatePlan.java} | 29 +-
.../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 +
.../template/DeactivateSchemaTemplateTask.java | 45 ++
.../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} | 44 +-
.../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 +-
129 files changed, 3926 insertions(+), 1419 deletions(-)