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/20 02:49:06 UTC
[iotdb] branch 1c1d_dockertest created (now 023ff5f7c4)
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
at 023ff5f7c4 1c1d
This branch includes the following new commits:
new 65a80b6d8d test
new 3de005e13b confignode
new 00d455cfc5 fix
new 7d27c91fe0 fix
new bf6654feb5 fix
new ae95d7561d fix
new a8981c6fc9 fix
new e202302bab fix
new 2446aefa24 fix
new 5436d33275 fix
new 5353c0ac79 fix
new a3c59d5ca7 Merge branch 'master' of https://github.com/apache/iotdb into 1c1d_dockertest
new 023ff5f7c4 1c1d
The 13 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.
[iotdb] 13/13: 1c1d
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 023ff5f7c46f7f26cdeb9f15ae1061fb2b0edee0
Author: HTHou <hh...@outlook.com>
AuthorDate: Thu Oct 20 10:46:43 2022 +0800
1c1d
---
.github/workflows/client-python.yml | 2 +-
docker/src/main/DockerCompose/start-1c1d.sh | 3 ++
docker/src/main/Dockerfile-1c1d | 52 +++++++++++++++++++++++++++++
3 files changed, 56 insertions(+), 1 deletion(-)
diff --git a/.github/workflows/client-python.yml b/.github/workflows/client-python.yml
index 9fb748fdaf..c92cd9f4ae 100644
--- a/.github/workflows/client-python.yml
+++ b/.github/workflows/client-python.yml
@@ -53,7 +53,7 @@ jobs:
run: mvn -B clean install -pl distribution,client-py -am -DskipTests
- name: Build IoTDB server docker image
run: |
- docker build . -f docker/src/main/Dockerfile-single -t "iotdb:dev"
+ docker build . -f docker/src/main/Dockerfile-1c1d -t "iotdb:dev"
docker images
- name: Install IoTDB python client requirements
run: pip3 install -r client-py/requirements_dev.txt
diff --git a/docker/src/main/DockerCompose/start-1c1d.sh b/docker/src/main/DockerCompose/start-1c1d.sh
new file mode 100644
index 0000000000..a6501b2a3e
--- /dev/null
+++ b/docker/src/main/DockerCompose/start-1c1d.sh
@@ -0,0 +1,3 @@
+#!/bin/bash
+./confignode/sbin/start-confignode.sh &
+./datanode/sbin/start-datanode.sh &
\ No newline at end of file
diff --git a/docker/src/main/Dockerfile-1c1d b/docker/src/main/Dockerfile-1c1d
new file mode 100644
index 0000000000..59cc6debca
--- /dev/null
+++ b/docker/src/main/Dockerfile-1c1d
@@ -0,0 +1,52 @@
+#
+# 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 \
+ && apt remove unzip -y \
+ && apt autoremove -y \
+ && apt purge --auto-remove -y \
+ && apt clean -y \
+RUN dos2unix /iotdb/start-1c1d.sh
+RUN dos2unix /iotdb/confignode/sbin/start-confignode.sh
+RUN dos2unix /iotdb/confignode/sbin/../conf/confignode-env.sh
+RUN dos2unix /iotdb/datanode/sbin/start-datanode.sh
+RUN dos2unix /iotdb/datanode/sbin/../conf/datanode-env.sh
+EXPOSE 6667
+EXPOSE 31999
+EXPOSE 5555
+EXPOSE 8086
+EXPOSE 8181
+VOLUME /iotdb/datanode/data
+VOLUME /iotdb/datanode/logs
+VOLUME /iotdb/confignode/data
+VOLUME /iotdb/confignode/logs
+ENV PATH="/iotdb/datanode/sbin/:/iotdb/confignode/sbin/:/iotdb/tools/:${PATH}"
+ENTRYPOINT ["/iotdb/start-1c1d.sh"]
[iotdb] 10/13: fix
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 5436d33275797156348daa0a0e3af260a1302785
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Sep 19 15:10:51 2022 +0800
fix
---
client-py/requirements.txt | 10 +++++-----
client-py/requirements_dev.txt | 10 +++++-----
docker/src/main/Dockerfile-single | 4 ++--
3 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/client-py/requirements.txt b/client-py/requirements.txt
index 8715d50595..83cf2c3aec 100644
--- a/client-py/requirements.txt
+++ b/client-py/requirements.txt
@@ -17,10 +17,10 @@
#
# Pandas Export
-pandas~=1.3.5
+pandas>=1.3.5
# Testcontainer
-testcontainers==3.3.0
-numpy~=1.21.4
+testcontainers>=3.3.0
+numpy>=1.21.4
# SQLAlchemy Dialect
-sqlalchemy == 1.3.20
-sqlalchemy-utils == 0.36.8
\ No newline at end of file
+sqlalchemy>=1.3.20
+sqlalchemy-utils>=0.36.8
\ No newline at end of file
diff --git a/client-py/requirements_dev.txt b/client-py/requirements_dev.txt
index 824831a319..c470e45e53 100644
--- a/client-py/requirements_dev.txt
+++ b/client-py/requirements_dev.txt
@@ -18,10 +18,10 @@
-r requirements.txt
# Pytest to run tests
-pytest==6.2.2
+pytest>=6.2.2
thrift==0.14.1
-flake8==3.9.0
-black==20.8b1
+flake8>=3.9.0
+black>=20.8b1
# For releases
-twine==3.4.1
-wheel==0.36.2
\ No newline at end of file
+twine>=3.4.1
+wheel>=0.36.2
\ No newline at end of file
diff --git a/docker/src/main/Dockerfile-single b/docker/src/main/Dockerfile-single
index ea929d3b6e..3c1629cd86 100644
--- a/docker/src/main/Dockerfile-single
+++ b/docker/src/main/Dockerfile-single
@@ -32,7 +32,7 @@ RUN apt update \
&& apt autoremove -y \
&& apt purge --auto-remove -y \
&& apt clean -y
-RUN dos2unix /iotdb/sbin/start-new-server.sh
+RUN dos2unix /iotdb/sbin/start-server.sh
RUN dos2unix /iotdb/sbin/../conf/datanode-env.sh
EXPOSE 6667
EXPOSE 31999
@@ -42,4 +42,4 @@ EXPOSE 8181
VOLUME /iotdb/data
VOLUME /iotdb/logs
ENV PATH="/iotdb/sbin/:/iotdb/tools/:${PATH}"
-ENTRYPOINT ["/iotdb/sbin/start-new-server.sh"]
+ENTRYPOINT ["/iotdb/sbin/start-server.sh"]
[iotdb] 12/13: 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 a3c59d5ca71023f29b1cb223b996dce38ef22ec5
Merge: 5353c0ac79 723ecb42cf
Author: HTHou <hh...@outlook.com>
AuthorDate: Thu Oct 20 10:19:38 2022 +0800
Merge branch 'master' of https://github.com/apache/iotdb into 1c1d_dockertest
.github/workflows/greetings.yml | 3 +-
.gitignore | 3 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 3 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 50 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 33 +-
cli/pom.xml | 5 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 5 +-
cli/src/main/java/org/apache/iotdb/cli/Cli.java | 19 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 54 +-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 8 +-
.../resources/conf/iotdb-confignode.properties | 83 +-
.../confignode/client/ConfigNodeRequestType.java | 2 +-
.../confignode/client/DataNodeRequestType.java | 59 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 70 +
.../client/async/AsyncDataNodeClientPool.java | 305 ++++
.../async/AsyncDataNodeHeartbeatClientPool.java | 72 +
.../AsyncConfigNodeHeartbeatClientPool.java | 70 -
.../async/datanode/AsyncDataNodeClientPool.java | 512 ------
.../datanode/AsyncDataNodeHeartbeatClientPool.java | 72 -
.../async/handlers/AbstractRetryHandler.java | 75 -
.../client/async/handlers/AsyncClientHandler.java | 204 +++
.../client/async/handlers/ClearCacheHandler.java | 81 -
.../async/handlers/ConfigNodeHeartbeatHandler.java | 45 -
.../handlers/ConstructSchemaBlackListHandler.java | 95 --
.../client/async/handlers/CreateRegionHandler.java | 91 --
.../async/handlers/DataNodeHeartbeatHandler.java | 80 -
.../DeleteDataForDeleteTimeSeriesHandler.java | 103 --
.../async/handlers/DeleteTimeSeriesHandler.java | 93 --
.../handlers/FetchSchemaBlackLsitHandler.java | 101 --
.../client/async/handlers/FlushHandler.java | 80 -
.../async/handlers/FunctionManagementHandler.java | 72 -
.../InvalidateMatchedSchemaCacheHandler.java | 95 --
.../async/handlers/LoadConfigurationHandler.java | 82 -
.../client/async/handlers/MergeHandler.java | 83 -
.../handlers/RollbackSchemaBlackListHandler.java | 99 --
.../async/handlers/SetSystemStatusHandler.java | 82 -
.../client/async/handlers/SetTTLHandler.java | 61 -
.../handlers/UpdateConfigNodeGroupHandler.java | 66 -
.../handlers/UpdateRegionRouteMapHandler.java | 63 -
.../heartbeat/ConfigNodeHeartbeatHandler.java | 45 +
.../heartbeat/DataNodeHeartbeatHandler.java | 82 +
.../handlers/rpc/AbstractAsyncRPCHandler.java | 84 +
.../handlers/rpc/AsyncTSStatusRPCHandler.java | 88 +
.../handlers/rpc/DeleteTimeSeriesRPCHandler.java | 84 +
.../rpc/FetchSchemaBlackListRPCHandler.java | 87 +
.../client/async/task/AbstractDataNodeTask.java | 53 -
.../task/ConstructSchemaBlackListDataNodeTask.java | 45 -
.../DeleteDataForDeleteTimeSeriesDataNodeTask.java | 46 -
.../async/task/DeleteTimeSeriesDataNodeTask.java | 45 -
.../task/FetchSchemaBlackListDataNodeTask.java | 46 -
.../InvalidateMatchedSchemaCacheDataNodeTask.java | 46 -
.../task/RollbackSchemaBlackListDataNodeTask.java | 45 -
.../client/sync/SyncConfigNodeClientPool.java | 151 ++
.../client/sync/SyncDataNodeClientPool.java | 167 ++
.../sync/confignode/SyncConfigNodeClientPool.java | 151 --
.../sync/datanode/SyncDataNodeClientPool.java | 204 ---
.../iotdb/confignode/conf/ConfigNodeConfig.java | 454 +++++-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 5 +
.../confignode/conf/ConfigNodeDescriptor.java | 227 ++-
.../confignode/conf/ConfigNodeRemoveCheck.java | 51 +-
.../confignode/conf/SystemPropertiesUtils.java | 20 +
.../consensus/request/ConfigPhysicalPlan.java | 124 +-
.../consensus/request/ConfigPhysicalPlanType.java | 23 +-
.../request/read/GetNodePathsPartitionPlan.java | 3 +-
.../consensus/request/read/GetRegionIdPlan.java | 112 ++
.../request/read/GetSeriesSlotListPlan.java | 84 +
.../request/read/GetTimeSlotListPlan.java | 109 ++
.../request/read/GetTransferringTriggersPlan.java | 42 +
.../consensus/request/read/GetTriggerJarPlan.java | 68 +
.../request/read/GetTriggerTablePlan.java | 62 +
.../write/AdjustMaxRegionGroupCountPlan.java | 89 -
.../request/write/ApplyConfigNodePlan.java | 73 -
.../request/write/CreateDataPartitionPlan.java | 99 --
.../request/write/CreateRegionGroupsPlan.java | 117 --
.../request/write/CreateSchemaPartitionPlan.java | 101 --
.../request/write/DeleteRegionGroupsPlan.java | 91 --
.../request/write/DeleteStorageGroupPlan.java | 70 -
.../request/write/PreDeleteStorageGroupPlan.java | 87 -
.../request/write/RemoveConfigNodePlan.java | 77 -
.../write/SetDataReplicationFactorPlan.java | 81 -
.../write/SetSchemaReplicationFactorPlan.java | 81 -
.../request/write/SetStorageGroupPlan.java | 72 -
.../consensus/request/write/SetTTLPlan.java | 91 --
.../write/SetTimePartitionIntervalPlan.java | 81 -
.../write/confignode/ApplyConfigNodePlan.java | 73 +
.../write/confignode/RemoveConfigNodePlan.java | 77 +
.../write/partition/CreateDataPartitionPlan.java | 99 ++
.../write/partition/CreateSchemaPartitionPlan.java | 101 ++
.../write/region/CreateRegionGroupsPlan.java | 117 ++
.../write/region/OfferRegionMaintainTasksPlan.java | 80 +
.../write/region/PollRegionMaintainTaskPlan.java | 43 +
.../AdjustMaxRegionGroupCountPlan.java | 89 +
.../write/storagegroup/DeleteStorageGroupPlan.java | 70 +
.../storagegroup/PreDeleteStorageGroupPlan.java | 87 +
.../storagegroup/SetDataReplicationFactorPlan.java | 81 +
.../SetSchemaReplicationFactorPlan.java | 81 +
.../write/storagegroup/SetStorageGroupPlan.java | 72 +
.../request/write/storagegroup/SetTTLPlan.java | 91 ++
.../storagegroup/SetTimePartitionIntervalPlan.java | 81 +
.../request/write/sync/CreatePipeSinkPlan.java | 57 +
.../consensus/request/write/sync/DropPipePlan.java | 56 +
.../request/write/sync/DropPipeSinkPlan.java | 56 +
.../request/write/sync/GetPipeSinkPlan.java | 56 +
.../request/write/sync/PreCreatePipePlan.java | 56 +
.../request/write/sync/SetPipeStatusPlan.java | 72 +
.../consensus/request/write/sync/ShowPipePlan.java | 56 +
.../write/trigger/AddTriggerInTablePlan.java | 84 +
.../write/trigger/DeleteTriggerInTablePlan.java | 62 +
.../write/trigger/UpdateTriggerLocationPlan.java | 76 +
.../trigger/UpdateTriggerStateInTablePlan.java | 75 +
.../trigger/UpdateTriggersOnTransferNodesPlan.java | 75 +
.../consensus/response/DataNodeRegisterResp.java | 11 +
.../consensus/response/GetRegionIdResp.java | 59 +
.../consensus/response/GetSeriesSlotListResp.java | 59 +
.../consensus/response/GetTimeSlotListResp.java | 59 +
.../confignode/consensus/response/PipeResp.java | 47 +
.../consensus/response/PipeSinkResp.java | 47 +
.../consensus/response/SchemaPartitionResp.java | 2 +-
.../response/TransferringTriggersResp.java | 43 +
.../consensus/response/TriggerJarResp.java | 52 +
.../consensus/response/TriggerTableResp.java | 70 +
.../statemachine/PartitionRegionStateMachine.java | 40 +-
.../NotAvailableRegionGroupException.java | 27 +
.../confignode/manager/ClusterSchemaManager.java | 84 +-
.../iotdb/confignode/manager/ConfigManager.java | 416 +++--
.../iotdb/confignode/manager/ConsensusManager.java | 99 +-
.../apache/iotdb/confignode/manager/IManager.java | 148 +-
.../iotdb/confignode/manager/NodeManager.java | 662 --------
.../iotdb/confignode/manager/PartitionManager.java | 615 -------
.../confignode/manager/PermissionManager.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 153 +-
.../iotdb/confignode/manager/SyncManager.java | 201 +++
.../iotdb/confignode/manager/TriggerManager.java | 224 +++
.../iotdb/confignode/manager/UDFManager.java | 33 +-
.../iotdb/confignode/manager/load/LoadManager.java | 38 +-
.../manager/load/LoadManagerMetrics.java | 4 +-
.../manager/load/balancer/PartitionBalancer.java | 7 +-
.../manager/load/balancer/RegionBalancer.java | 46 +-
.../manager/load/balancer/RouteBalancer.java | 10 +-
.../partition/GreedyPartitionAllocator.java | 175 +-
.../balancer/partition/IPartitionAllocator.java | 7 +-
.../balancer/region/CopySetRegionAllocator.java | 4 +-
.../balancer/region/GreedyRegionAllocator.java | 4 +-
.../load/balancer/region/IRegionAllocator.java | 4 +-
.../manager/load/balancer/router/IRouter.java | 2 +-
.../load/balancer/router/LazyGreedyRouter.java | 2 +-
.../manager/load/balancer/router/LeaderRouter.java | 2 +-
.../balancer/router/LoadScoreGreedyRouter.java | 2 +-
.../manager/load/heartbeat/BaseNodeCache.java | 74 -
.../load/heartbeat/ConfigNodeHeartbeatCache.java | 85 -
.../load/heartbeat/DataNodeHeartbeatCache.java | 102 --
.../manager/load/heartbeat/IRegionGroupCache.java | 59 -
.../load/heartbeat/NodeHeartbeatSample.java | 68 -
.../manager/load/heartbeat/RegionGroupCache.java | 122 --
.../load/heartbeat/RegionHeartbeatSample.java | 56 -
.../confignode/manager/node/BaseNodeCache.java | 80 +
.../manager/node/ConfigNodeHeartbeatCache.java | 78 +
.../manager/node/DataNodeHeartbeatCache.java | 80 +
.../manager/node/NodeHeartbeatSample.java | 87 +
.../iotdb/confignode/manager/node/NodeManager.java | 901 ++++++++++
.../manager/partition/PartitionManager.java | 860 ++++++++++
.../confignode/manager/partition/RegionCache.java | 91 ++
.../manager/partition/RegionGroupCache.java | 122 ++
.../manager/partition/RegionGroupStatus.java | 59 +
.../manager/partition/RegionHeartbeatSample.java | 68 +
.../iotdb/confignode/persistence/NodeInfo.java | 16 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 303 ++++
.../persistence/executor/ConfigPlanExecutor.java | 100 +-
.../persistence/metric/NodeInfoMetrics.java | 2 +-
.../persistence/partition/PartitionInfo.java | 196 ++-
.../persistence/partition/RegionCreateTask.java | 135 ++
.../persistence/partition/RegionDeleteTask.java | 98 ++
.../persistence/partition/RegionGroup.java | 2 +-
.../persistence/partition/RegionMaintainTask.java | 131 ++
.../persistence/partition/RegionMaintainType.java | 24 +
.../partition/StorageGroupPartitionTable.java | 75 +-
.../persistence/schema/ClusterSchemaInfo.java | 14 +-
.../persistence/sync/ClusterSyncInfo.java | 189 +++
.../confignode/procedure/ProcedureExecutor.java | 3 +-
.../procedure/StateMachineProcedure.java | 330 ----
.../procedure/env/ConfigNodeProcedureEnv.java | 279 +++-
.../procedure/env/DataNodeRemoveHandler.java | 218 +--
.../procedure/impl/AbstractNodeProcedure.java | 64 -
.../procedure/impl/AddConfigNodeProcedure.java | 163 --
.../impl/CreateRegionGroupsProcedure.java | 212 ---
.../procedure/impl/CreateTriggerProcedure.java | 295 ++++
.../impl/DeleteStorageGroupProcedure.java | 183 ---
.../procedure/impl/DeleteTimeSeriesProcedure.java | 639 --------
.../procedure/impl/DropTriggerProcedure.java | 176 ++
.../procedure/impl/RegionMigrateProcedure.java | 296 ----
.../procedure/impl/RemoveConfigNodeProcedure.java | 144 --
.../procedure/impl/RemoveDataNodeProcedure.java | 186 ---
.../procedure/impl/node/AbstractNodeProcedure.java | 64 +
.../impl/node/AddConfigNodeProcedure.java | 166 ++
.../impl/node/RemoveConfigNodeProcedure.java | 144 ++
.../impl/node/RemoveDataNodeProcedure.java | 192 +++
.../statemachine/CreateRegionGroupsProcedure.java | 269 +++
.../statemachine/DeleteStorageGroupProcedure.java | 210 +++
.../statemachine/DeleteTimeSeriesProcedure.java | 658 ++++++++
.../impl/statemachine/RegionMigrateProcedure.java | 309 ++++
.../impl/statemachine/StateMachineProcedure.java | 331 ++++
.../impl/sync/AbstractOperatePipeProcedure.java | 144 ++
.../procedure/impl/sync/CreatePipeProcedure.java | 147 ++
.../procedure/impl/sync/DropPipeProcedure.java | 137 ++
.../procedure/impl/sync/StartPipeProcedure.java | 132 ++
.../procedure/impl/sync/StopPipeProcedure.java | 132 ++
.../procedure/state/AddConfigNodeState.java | 2 +-
.../procedure/state/CreateRegionGroupsState.java | 11 +-
.../procedure/state/CreateTriggerState.java | 29 +
.../procedure/state/DeleteTimeSeriesState.java | 2 +-
.../procedure/state/DropTriggerState.java | 27 +
.../procedure/state/RemoveConfigNodeState.java | 2 +-
.../procedure/state/sync/OperatePipeState.java | 26 +
.../procedure/store/ProcedureFactory.java | 58 +-
.../iotdb/confignode/service/ConfigNode.java | 54 +-
.../confignode/service/ConfigNodeCommandLine.java | 32 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 217 ++-
.../request/ConfigPhysicalPlanSerDeTest.java | 405 ++++-
.../hash/DeviceGroupHashExecutorManualTest.java | 2 +-
.../load/balancer/router/LazyGreedyRouterTest.java | 8 +-
.../load/balancer/router/LeaderRouterTest.java | 68 +-
.../balancer/router/LoadScoreGreedyRouterTest.java | 8 +-
.../manager/partition/RegionGroupCacheTest.java | 124 ++
.../persistence/ClusterSchemaInfoTest.java | 2 +-
.../persistence/ClusterSyncInfoTest.java | 116 ++
.../confignode/persistence/PartitionInfoTest.java | 39 +-
.../confignode/persistence/TriggerInfoTest.java | 120 ++
.../procedure/entity/SimpleSTMProcedure.java | 2 +-
.../procedure/entity/StuckSTMProcedure.java | 2 +-
.../impl/CreateRegionGroupsProcedureTest.java | 15 +-
.../procedure/impl/CreateTriggerProcedureTest.java | 111 ++
.../impl/DeleteStorageGroupProcedureTest.java | 58 +
.../impl/DeleteTimeSeriesProcedureTest.java | 1 +
.../procedure/impl/DropTriggerProcedureTest.java | 55 +
.../procedure/impl/OperatePipeProcedureTest.java | 122 ++
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 336 ----
.../confignode1conf/iotdb-confignode.properties | 22 +-
.../confignode2conf/iotdb-confignode.properties | 14 +-
.../confignode3conf/iotdb-confignode.properties | 12 +-
consensus/pom.xml | 2 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 5 +-
.../org/apache/iotdb/consensus/common/Peer.java | 26 +-
.../request/BatchIndexedConsensusRequest.java | 8 +-
.../common/request/IndexedConsensusRequest.java | 8 +
.../iotdb/consensus/config/ConsensusConfig.java | 22 +-
.../iotdb/consensus/config/MultiLeaderConfig.java | 41 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 122 +-
.../exception/ConsensusGroupAddPeerException.java | 34 +
.../multileader/MultiLeaderConsensus.java | 107 +-
.../multileader/MultiLeaderServerImpl.java | 339 +++-
.../multileader/client/DispatchLogHandler.java | 10 +-
.../client/MultiLeaderConsensusClientPool.java | 24 +
.../client/SyncMultiLeaderServiceClient.java | 144 ++
.../multileader/logdispatcher/IndexController.java | 43 +-
.../multileader/logdispatcher/LogDispatcher.java | 228 ++-
.../logdispatcher/MultiLeaderMemoryManager.java | 72 +
.../multileader/logdispatcher/PendingBatch.java | 11 +-
.../service/MultiLeaderRPCServiceProcessor.java | 179 +-
.../multileader/snapshot/SnapshotFragment.java | 81 +
.../snapshot/SnapshotFragmentReader.java | 69 +
.../ratis/ApplicationStateMachineProxy.java | 40 +-
.../ratis/FileInfoWithDelayedMd5Computing.java | 75 -
.../iotdb/consensus/ratis/RatisConsensus.java | 33 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 143 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 44 +-
.../consensus/standalone/StandAloneConsensus.java | 11 +-
.../consensus/standalone/StandAloneServerImpl.java | 2 +-
.../multileader/MultiLeaderConsensusTest.java | 71 +-
.../iotdb/consensus/multileader/RecoveryTest.java | 5 +-
.../logdispatcher/IndexControllerTest.java | 41 +-
.../multileader/logdispatcher/SyncStatusTest.java | 38 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 7 +-
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 35 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 7 +-
.../iotdb/consensus/standalone/RecoveryTest.java | 5 +-
.../standalone/StandAloneConsensusTest.java | 30 +-
docs/Download/README.md | 14 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 2 +-
docs/UserGuide/API/RestService.md | 2 +-
.../Administration-Management/Administration.md | 2 +-
docs/UserGuide/{Process-Data => Alert}/Alerting.md | 0
docs/UserGuide/{Process-Data => Alert}/Triggers.md | 0
docs/UserGuide/Cluster/Cluster-Concept.md | 18 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 70 +-
docs/UserGuide/Data-Concept/Time-Partition.md | 20 +-
docs/UserGuide/Data-Concept/Time-zone.md | 2 +-
.../Delete-Data.md | 0
docs/UserGuide/Delete-Data/TTL.md | 90 +
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 4 +-
.../Maintenance-Tools/Maintenance-Command.md | 444 +++--
docs/UserGuide/Operate-Metadata/Storage-Group.md | 3 +
docs/UserGuide/Operate-Metadata/TTL.md | 78 -
docs/UserGuide/Operate-Metadata/Timeseries.md | 3 +-
docs/UserGuide/Query-Data/Aggregate-Query.md | 174 ++
docs/UserGuide/Query-Data/Select-Expression.md | 2 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 14 +
.../Reference/ConfigNode-Config-Manual.md | 13 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 40 +-
docs/UserGuide/Reference/SQL-Reference.md | 3 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 2 +-
docs/UserGuide/UDF-Library/Data-Profiling.md | 10 +-
.../Write-And-Delete-Data/Load-External-Tsfile.md | 92 --
docs/UserGuide/Write-And-Delete-Data/Write-Data.md | 108 --
.../CSV-Tool.md | 0
docs/UserGuide/Write-Data/Load-External-Tsfile.md | 94 ++
.../TsFile-Tool.md | 0
docs/UserGuide/Write-Data/Write-Data.md | 110 ++
docs/zh/Download/README.md | 14 +-
.../UserGuide/API/Programming-Java-Native-API.md | 2 +-
docs/zh/UserGuide/API/RestService.md | 2 +-
.../Administration-Management/Administration.md | 2 +-
.../UserGuide/{Process-Data => Alert}/Alerting.md | 0
.../UserGuide/{Process-Data => Alert}/Triggers.md | 0
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 68 +-
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 28 +-
docs/zh/UserGuide/Data-Concept/Time-zone.md | 2 +-
.../Delete-Data.md | 0
docs/zh/UserGuide/Delete-Data/TTL.md | 89 +
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 4 +-
.../Maintenance-Tools/Maintenance-Command.md | 449 ++---
.../zh/UserGuide/Operate-Metadata/Storage-Group.md | 2 +
docs/zh/UserGuide/Operate-Metadata/TTL.md | 75 -
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 3 +-
docs/zh/UserGuide/Query-Data/Aggregate-Query.md | 168 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 2 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 14 +
.../Reference/ConfigNode-Config-Manual.md | 17 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 51 +-
docs/zh/UserGuide/Reference/SQL-Reference.md | 3 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 2 +-
docs/zh/UserGuide/UDF-Library/Data-Profiling.md | 6 +-
.../Write-And-Delete-Data/Load-External-Tsfile.md | 91 --
.../UserGuide/Write-And-Delete-Data/Write-Data.md | 110 --
.../CSV-Tool.md | 0
.../UserGuide/Write-Data/Load-External-Tsfile.md | 93 ++
.../TsFile-Tool.md | 0
docs/zh/UserGuide/Write-Data/Write-Data.md | 112 ++
example/ext-pipe-plugin-example/pom.xml | 12 +-
.../iotdb/extpipe/ExtPipeSinkWriterFactory.java | 47 +-
.../iotdb/extpipe/ExtPipeSinkWriterImpl.java | 124 +-
example/kafka/pom.xml | 2 +-
example/pom.xml | 1 +
example/pulsar/pom.xml | 2 +-
example/trigger/pom.xml | 7 +-
.../org/apache/iotdb/trigger/AlertingExample.java | 108 --
.../iotdb/trigger/ClusterAlertingExample.java | 99 ++
.../org/apache/iotdb/trigger/LoggerTrigger.java | 86 +
.../org/apache/iotdb/trigger/SimpleTrigger.java | 38 +
.../org/apache/iotdb/trigger/TriggerExample.java | 147 --
.../apache/iotdb/trigger/old/AlertingExample.java | 108 ++
.../apache/iotdb/trigger/old/TriggerExample.java | 147 ++
.../pipe/external/api/IExternalPipeSinkWriter.java | 30 +-
.../util/TSFileConfigUtilCompletenessTest.java | 3 +-
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 12 +-
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 22 +-
.../standalone/Apache IoTDB Dashboard v0.13.1.json | 1527 -----------------
.../standalone/Apache IoTDB Dashboard v0.14.0.json | 8 +-
hive-connector/pom.xml | 2 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 12 +-
integration-test/checkstyle.xml | 8 +-
integration-test/import-control.xml | 81 +-
.../trigger/example/TriggerFireTimesCounter.java | 87 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 96 +-
.../java/org/apache/iotdb/it/env/Cluster1Env.java | 6 +
.../java/org/apache/iotdb/it/env/MppConfig.java | 52 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 37 +-
.../apache/iotdb/it/env/StandaloneOnMppEnv.java | 5 +
.../iotdb/it/framework/IoTDBTestReporter.java | 18 +-
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 232 +++
.../org/apache/iotdb/itbase/env/BaseConfig.java | 56 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 77 +-
.../confignode/it/IoTDBClusterPartitionIT.java | 790 +++++++++
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 88 +
.../iotdb/confignode/it/IoTDBConfigNodeIT.java | 848 ++++++++++
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 279 ++++
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 183 +++
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 560 +++++--
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 24 +
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 24 +-
.../org/apache/iotdb/db/it/IoTDBFilterNullIT.java | 3 +
.../it/aggregation/IoTDBAggregationByLevelIT.java | 3 +
.../it/aggregation/IoTDBAggregationDeleteIT.java | 3 +
.../aggregation/IoTDBAggregationScanOrderIT.java | 3 +
.../aggregation/IoTDBAggregationSmallDataIT.java | 3 +
.../db/it/aggregation/IoTDBTagAggregationIT.java | 514 ++++++
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 2 +-
.../iotdb/db/it/aligned/AlignedWriteUtil.java | 148 --
.../aligned/IoTDBAggregationWithDeletion2IT.java | 1 +
.../it/aligned/IoTDBAggregationWithDeletionIT.java | 1 +
.../db/it/aligned/IoTDBAlignedLastQuery2IT.java | 1 +
.../db/it/aligned/IoTDBAlignedLastQuery3IT.java | 1 +
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 1 +
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 1 +
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 1 +
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 1 +
.../IoTDBAlignedSeriesQueryWithDeletionIT.java | 1 +
.../IoTDBCountMultiTimesWithDeletionIT.java | 146 ++
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 65 +-
...GroupByQueryWithValueFilterWithDeletion2IT.java | 1 +
...BGroupByQueryWithValueFilterWithDeletionIT.java | 1 +
...upByQueryWithoutValueFilterWithDeletion2IT.java | 1 +
...oupByQueryWithoutValueFilterWithDeletionIT.java | 1 +
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 34 +
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 1 +
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 1 +
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 1 +
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 1 +
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 1 +
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 1 +
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 1 +
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 1 +
.../confignode/IoTDBClusterPartitionTableTest.java | 352 ----
.../iotdb/db/it/confignode/IoTDBConfigNodeIT.java | 848 ----------
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 76 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 28 +-
.../apache/iotdb/db/it/groupby/IoTDBHavingIT.java | 109 +-
.../db/it/schema/IoTDBDeleteTimeseriesIT.java | 53 +
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 102 ++
.../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 72 +-
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 15 +-
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 265 +++
.../apache/iotdb/db/it/utils/AlignedWriteUtil.java | 148 ++
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 3 +
.../db/it/withoutNull/IoTDBWithoutAnyNullIT.java | 3 +
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 3 +
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 3 +
.../session/it/IoTDBSessionAlignedInsertIT.java | 456 ++++++
.../iotdb/session/it/IoTDBSessionComplexIT.java | 559 +++++++
.../it/IoTDBSessionDisableMemControlIT.java | 222 +++
.../iotdb/session/it/IoTDBSessionInsertNulIT.java | 360 ++++
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 337 ++++
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 1635 +++++++++++++++++++
.../session/it/IoTDBSessionSyntaxConventionIT.java | 430 +++++
.../org/apache/iotdb/session/it/SessionIT.java | 185 +++
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 0 -> 1324 bytes
.../src/test/resources/trigger-example.jar | Bin 0 -> 9221 bytes
.../iotdb/db/integration/IoTDBCompactionIT.java | 3 +-
.../integration/IoTDBCompactionWithIDTableIT.java | 3 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 2 +-
...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 329 ----
.../db/integration/IoTDBLoadExternalTsfileIT.java | 9 +-
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 3 +-
.../db/integration/IoTDBRepeatPatternNameIT.java | 67 +
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 11 +-
.../iotdb/db/integration/IoTDBSnapshotIT.java | 60 +-
.../iotdb/db/integration/IoTDBTimePartitionIT.java | 3 +-
.../aggregation/IoTDBUDFNestAggregationIT.java | 3 +-
.../IoTDBUserDefinedAggregationFunctionIT.java | 8 +-
.../aligned/IoTDBGroupByFillQueryBigDataIT.java | 3 +-
.../aligned/IoTDBGroupByFillQueryIT.java | 3 +-
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 9 +-
.../db/integration/env/StandaloneEnvConfig.java | 2 +-
.../db/integration/groupby/IoTDBGroupByFillIT.java | 2 +-
.../groupby/IoTDBGroupByFillMixPathsIT.java | 2 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 2 +-
.../IoTDBDeletionVersionAdaptionIT.java | 3 +-
.../session/IoTDBSessionAlignedABDeviceIT.java | 234 +++
.../session/IoTDBSessionAlignedAggregationIT.java | 262 +++
.../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 195 +++
.../iotdb/session/IoTDBSessionComplexIT.java | 929 -----------
.../session/IoTDBSessionDisableMemControlIT.java | 202 ---
.../iotdb/session/IoTDBSessionInsertNullT.java | 298 ----
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 1704 -------------------
.../session/IoTDBSessionSyntaxConventionIT.java | 415 -----
.../session/IoTDBSessionVectorABDeviceIT.java | 233 ---
.../session/IoTDBSessionVectorAggregationIT.java | 262 ---
.../IoTDBSessionVectorAggregationWithUnSeqIT.java | 195 ---
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 516 ------
.../java/org/apache/iotdb/session/SessionTest.java | 673 --------
.../apache/iotdb/session/pool/SessionPoolTest.java | 16 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 2 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 15 +-
library-udf/pom.xml | 12 +
.../apache/iotdb/library/dprofile/UDTFSample.java | 70 +-
.../iotdb/library/dprofile/DProfileTests.java | 13 +
.../reporter/DropwizardPrometheusReporter.java | 3 +
metrics/interface/pom.xml | 2 +-
.../reporter/MicrometerPrometheusReporter.java | 6 +-
node-commons/pom.xml | 32 +
.../apache/iotdb/commons/cluster/NodeStatus.java | 1 +
.../apache/iotdb/commons/cluster/RegionStatus.java | 24 +-
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 49 +-
.../iotdb/commons/conf/CommonDescriptor.java | 11 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 31 +-
.../runtime/SerializationRunTimeException.java | 27 +
.../exception/sync/PipeAlreadyExistException.java | 31 +
.../exception/sync/PipeDataLoadException.java | 25 +
.../commons/exception/sync/PipeException.java | 36 +
.../exception/sync/PipeNotExistException.java | 25 +
.../exception/sync/PipeServerException.java | 34 +
.../sync/PipeSinkAlreadyExistException.java | 25 +
.../exception/sync/PipeSinkBeingUsedException.java | 27 +
.../commons/exception/sync/PipeSinkException.java | 42 +
.../exception/sync/PipeSinkNotExistException.java | 25 +
.../commons/executable/ExecutableManager.java | 157 +-
.../iotdb/commons/partition/DataPartition.java | 8 +-
.../commons/partition/DataPartitionTable.java | 37 +-
.../commons/partition/SchemaPartitionTable.java | 13 +
.../commons/partition/SeriesPartitionTable.java | 29 +
.../org/apache/iotdb/commons/path/AlignedPath.java | 348 ++++
.../apache/iotdb/commons/path/MeasurementPath.java | 297 ++++
.../org/apache/iotdb/commons/path/PartialPath.java | 51 +-
.../iotdb/commons/path/PathDeserializeUtil.java | 42 +
.../apache/iotdb/commons/path/PathPatternNode.java | 43 +-
.../org/apache/iotdb/commons/path/PathType.java | 9 +-
.../apache/iotdb/commons/path/PatternTreeMap.java | 74 +-
.../apache/iotdb/commons/service/ServiceType.java | 3 -
.../apache/iotdb/commons/sync/SyncConstant.java | 86 -
.../apache/iotdb/commons/sync/SyncPathUtil.java | 161 --
.../iotdb/commons/sync/metadata/SyncMetadata.java | 235 +++
.../commons/sync/persistence/SyncLogReader.java | 111 ++
.../commons/sync/persistence/SyncLogWriter.java | 95 ++
.../apache/iotdb/commons/sync/pipe/PipeInfo.java | 179 ++
.../iotdb/commons/sync/pipe/PipeMessage.java | 58 +
.../apache/iotdb/commons/sync/pipe/PipeStatus.java | 30 +
.../iotdb/commons/sync/pipe/SyncOperation.java | 30 +
.../iotdb/commons/sync/pipe/TsFilePipeInfo.java | 145 ++
.../iotdb/commons/sync/pipesink/IoTDBPipeSink.java | 185 +++
.../iotdb/commons/sync/pipesink/PipeSink.java | 93 ++
.../iotdb/commons/sync/utils/SyncConstant.java | 86 +
.../iotdb/commons/sync/utils/SyncPathUtil.java | 161 ++
.../iotdb/commons/trigger/TriggerInformation.java | 81 +-
.../apache/iotdb/commons/trigger/TriggerTable.java | 104 +-
.../exception/TriggerJarToLargeException.java | 30 -
.../exception/TriggerJarTooLargeException.java | 30 +
.../trigger/service/TriggerClassLoader.java | 55 -
.../trigger/service/TriggerClassLoaderManager.java | 103 --
.../trigger/service/TriggerExecutableManager.java | 34 +-
.../commons/udf/service/UDFExecutableManager.java | 6 +
.../udf/service/UDFRegistrationService.java | 6 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 1 +
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 6 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 38 +
.../commons/sync/metedata/SyncMetadataTest.java | 189 +++
pom.xml | 6 +-
.../java/org/apache/iotdb/RewriteTsFileTool.java | 249 ++-
.../schemaregion/rocksdb/RSchemaRegion.java | 179 +-
.../rocksdb/mnode/RMeasurementMNode.java | 2 +-
.../resources/conf/iotdb-datanode.properties | 68 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 270 ++-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 411 ++++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 126 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 4 +-
.../org/apache/iotdb/db/conf/IoTDBStopCheck.java | 76 -
.../db/consensus/DataRegionConsensusImpl.java | 69 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 72 +
.../statemachine/DataRegionStateMachine.java | 167 +-
.../statemachine/SchemaRegionStateMachine.java | 1 -
.../org/apache/iotdb/db/engine/StorageEngine.java | 21 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 80 +-
.../iotdb/db/engine/TsFileMetricManager.java | 69 +
.../engine/compaction/CompactionTaskManager.java | 6 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 29 +-
.../RewriteCrossSpaceCompactionSelector.java | 64 +-
.../rewrite/task/ReadPointPerformerSubTask.java | 10 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 7 +
.../utils/AlignedSeriesCompactionExecutor.java | 1 +
.../inner/utils/MultiTsFileDeviceIterator.java | 79 +-
.../utils/SingleSeriesCompactionExecutor.java | 1 +
.../compaction/performer/ICompactionPerformer.java | 4 +-
.../impl/ReadChunkCompactionPerformer.java | 34 +-
.../impl/ReadPointCompactionPerformer.java | 200 +--
.../compaction/reader/SeriesDataBlockReader.java | 4 +-
.../compaction/task/CompactionRecoverTask.java | 7 +
.../writer/AbstractCompactionWriter.java | 12 +-
.../writer/CrossSpaceCompactionWriter.java | 65 +-
.../writer/InnerSpaceCompactionWriter.java | 48 +-
.../iotdb/db/engine/cq/ContinuousQueryService.java | 10 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 28 +-
.../iotdb/db/engine/load/AlignedChunkData.java | 19 +-
.../org/apache/iotdb/db/engine/load/ChunkData.java | 14 +-
.../apache/iotdb/db/engine/load/DeletionData.java | 72 +
.../iotdb/db/engine/load/LoadTsFileManager.java | 153 +-
.../iotdb/db/engine/load/NonAlignedChunkData.java | 9 +-
.../apache/iotdb/db/engine/load/TsFileData.java | 46 +
.../iotdb/db/engine/memtable/AbstractMemTable.java | 122 +-
.../engine/memtable/AlignedWritableMemChunk.java | 23 +-
.../memtable/AlignedWritableMemChunkGroup.java | 32 +-
.../db/engine/memtable/IWritableMemChunk.java | 16 +-
.../db/engine/memtable/IWritableMemChunkGroup.java | 5 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 29 +-
.../db/engine/memtable/WritableMemChunkGroup.java | 54 +-
.../iotdb/db/engine/modification/Deletion.java | 54 +-
.../db/engine/querycontext/QueryDataSource.java | 5 +-
.../iotdb/db/engine/snapshot/SnapshotFileSet.java | 4 +-
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 383 +++--
.../db/engine/snapshot/SnapshotLogAnalyzer.java | 61 +-
.../iotdb/db/engine/snapshot/SnapshotLogger.java | 47 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 41 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 173 +-
.../db/engine/storagegroup/DataRegionInfo.java | 99 ++
.../db/engine/storagegroup/StorageGroupInfo.java | 96 --
.../db/engine/storagegroup/TsFileManager.java | 5 +-
.../db/engine/storagegroup/TsFileProcessor.java | 88 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 16 +-
.../db/engine/storagegroup/TsFileResource.java | 114 +-
.../dataregion/StorageGroupManager.java | 6 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 57 +-
.../storagegroup/timeindex/FileTimeIndex.java | 51 +-
.../engine/storagegroup/timeindex/ITimeIndex.java | 24 +
.../storagegroup/timeindex/V012FileTimeIndex.java | 32 +-
.../engine/trigger/executor/TriggerExecutor.java | 2 +-
.../trigger/service/TriggerClassLoaderManager.java | 2 +-
.../service/TriggerRegistrationService.java | 2 +-
.../db/exception/VerifyMetadataException.java | 38 +
.../metadata/MeasurementAlreadyExistException.java | 2 +-
.../schemafile/ColossalRecordException.java | 53 +
.../schemafile/SchemaPageOverflowException.java | 3 +-
.../schemafile/SegmentNotFoundException.java | 11 +
.../schemafile/SegmentOverflowException.java | 7 +
.../query/QueryTimeoutRuntimeException.java | 9 +
.../runtime/SerializationRunTimeException.java | 27 -
.../iotdb/db/exception/sql/SemanticException.java | 4 +
.../db/exception/sync/PipeDataLoadException.java | 25 -
.../iotdb/db/exception/sync/PipeException.java | 36 -
.../db/exception/sync/PipeServerException.java | 34 -
.../iotdb/db/exception/sync/PipeSinkException.java | 42 -
.../iotdb/db/localconfignode/LocalConfigNode.java | 29 +-
.../localconfignode/LocalDataPartitionTable.java | 2 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 10 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 5 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 11 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 12 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 12 +-
.../idtable/entry/InsertMeasurementMNode.java | 2 +-
.../db/metadata/lastCache/LastCacheManager.java | 2 +-
.../db/metadata/logfile/BufferedSerializer.java | 54 +
.../db/metadata/logfile/FakeCRC32Deserializer.java | 91 ++
.../db/metadata/logfile/FakeCRC32Serializer.java | 65 +
.../iotdb/db/metadata/logfile/IDeserializer.java | 41 +
.../iotdb/db/metadata/logfile/ISerializer.java | 42 +
.../iotdb/db/metadata/logfile/MLogTxtWriter.java | 2 +-
.../iotdb/db/metadata/logfile/SchemaLogReader.java | 247 +++
.../iotdb/db/metadata/logfile/SchemaLogWriter.java | 114 ++
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 2 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 2 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 7 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 17 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 121 +-
.../store/disk/schemafile/AliasIndexPage.java | 518 ++++++
.../mtree/store/disk/schemafile/ISchemaPage.java | 171 +-
.../mtree/store/disk/schemafile/ISegment.java | 71 +-
.../store/disk/schemafile/ISegmentedPage.java | 97 ++
.../mtree/store/disk/schemafile/InternalPage.java | 583 +++++++
.../mtree/store/disk/schemafile/RecordUtils.java | 84 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 735 +--------
.../store/disk/schemafile/SchemaFileConfig.java | 88 +
.../mtree/store/disk/schemafile/SchemaPage.java | 598 +------
.../mtree/store/disk/schemafile/Segment.java | 737 +++------
.../mtree/store/disk/schemafile/SegmentedPage.java | 580 +++++++
.../store/disk/schemafile/WrappedSegment.java | 479 ++++++
.../disk/schemafile/pagemgr/BTreePageManager.java | 496 ++++++
.../disk/schemafile/pagemgr/IPageManager.java | 59 +
.../store/disk/schemafile/pagemgr/PageManager.java | 619 +++++++
.../db/metadata/mtree/traverser/Traverser.java | 26 +-
.../traverser/collector/MeasurementCollector.java | 2 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 350 ----
.../iotdb/db/metadata/path/MeasurementPath.java | 231 ---
.../db/metadata/path/PathDeserializeUtil.java | 43 -
.../db/metadata/path/PatternTreeMapFactory.java | 127 +-
.../plan/schemaregion/ISchemaRegionPlan.java | 27 +
.../plan/schemaregion/SchemaRegionPlanType.java | 75 +
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 90 +
.../impl/ActivateTemplateInClusterPlanImpl.java | 79 +
.../impl/ActivateTemplatePlanImpl.java | 44 +
.../impl/AutoCreateDeviceMNodePlanImpl.java | 44 +
.../schemaregion/impl/ChangeAliasPlanImpl.java | 55 +
.../schemaregion/impl/ChangeTagOffsetPlanImpl.java | 55 +
.../impl/CreateAlignedTimeSeriesPlanImpl.java | 171 ++
.../impl/CreateTimeSeriesPlanImpl.java | 163 ++
.../impl/DeleteTimeSeriesPlanImpl.java | 45 +
.../impl/PreDeleteTimeSeriesPlanImpl.java | 44 +
.../impl/RollbackPreDeleteTimeSeriesPlanImpl.java | 44 +
.../impl/SchemaRegionPlanDeserializer.java | 337 ++++
.../schemaregion/impl/SchemaRegionPlanFactory.java | 140 ++
.../impl/SchemaRegionPlanSerializer.java | 399 +++++
.../impl/SchemaRegionPlanTxtSerializer.java | 238 +++
.../schemaregion/impl/SetTemplatePlanImpl.java | 69 +
.../schemaregion/impl/UnsetTemplatePlanImpl.java | 69 +
.../write/IActivateTemplateInClusterPlan.java | 60 +
.../schemaregion/write/IActivateTemplatePlan.java | 42 +
.../write/IAutoCreateDeviceMNodePlan.java | 42 +
.../plan/schemaregion/write/IChangeAliasPlan.java | 46 +
.../schemaregion/write/IChangeTagOffsetPlan.java | 46 +
.../write/ICreateAlignedTimeSeriesPlan.java | 80 +
.../schemaregion/write/ICreateTimeSeriesPlan.java | 79 +
.../schemaregion/write/IDeleteTimeSeriesPlan.java | 44 +
.../write/IPreDeleteTimeSeriesPlan.java | 42 +
.../write/IRollbackPreDeleteTimeSeriesPlan.java | 42 +
.../plan/schemaregion/write/ISetTemplatePlan.java | 45 +
.../schemaregion/write/IUnsetTemplatePlan.java | 45 +
.../db/metadata/schemaregion/ISchemaRegion.java | 49 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 611 ++++---
.../schemaregion/SchemaRegionSchemaFileImpl.java | 417 +++--
.../apache/iotdb/db/metadata/tag/TagManager.java | 15 +
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 4 +-
.../db/metadata/utils/ResourceByPathUtils.java | 6 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 92 +-
.../iotdb/db/mpp/aggregation/Accumulator.java | 6 +-
.../iotdb/db/mpp/aggregation/Aggregator.java | 42 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 101 +-
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 33 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 101 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 138 +-
.../mpp/aggregation/FirstValueDescAccumulator.java | 122 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 132 +-
.../mpp/aggregation/LastValueDescAccumulator.java | 128 +-
.../db/mpp/aggregation/MaxTimeAccumulator.java | 23 +-
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 24 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 103 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 24 +-
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 21 +-
.../db/mpp/aggregation/MinValueAccumulator.java | 103 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 103 +-
.../slidingwindow/SlidingWindowAggregator.java | 2 +
.../timerangeiterator/AggrWindowIterator.java | 22 +-
.../TimeRangeIteratorFactory.java | 2 +-
.../iotdb/db/mpp/common/MPPQueryContext.java | 12 +-
.../org/apache/iotdb/db/mpp/common/NodeRef.java | 6 +-
.../iotdb/db/mpp/common/filter/FunctionFilter.java | 2 +-
.../iotdb/db/mpp/common/filter/QueryFilter.java | 2 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 73 +-
.../iotdb/db/mpp/common/header/DatasetHeader.java | 17 +
.../db/mpp/common/header/DatasetHeaderFactory.java | 22 +
.../mpp/common/schematree/ClusterSchemaTree.java | 11 +-
.../common/schematree/DeviceGroupSchemaTree.java | 2 +-
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 2 +-
.../db/mpp/common/schematree/ISchemaTree.java | 2 +-
.../schematree/node/SchemaMeasurementNode.java | 14 +
.../visitor/SchemaTreeMeasurementVisitor.java | 3 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 1 -
.../execution/exchange/MPPDataExchangeManager.java | 2 +-
.../execution/exchange/MPPDataExchangeService.java | 8 +-
.../db/mpp/execution/exchange/SourceHandle.java | 31 +-
.../execution/executor/RegionExecutionResult.java | 55 +
.../mpp/execution/executor/RegionReadExecutor.java | 78 +
.../execution/executor/RegionWriteExecutor.java | 507 ++++++
.../fragment/FragmentInstanceExecution.java | 12 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 12 +-
.../db/mpp/execution/operator/AggregationUtil.java | 6 +-
.../operator/process/AggregationOperator.java | 3 +-
.../process/RawDataAggregationOperator.java | 100 +-
.../process/SingleInputAggregationOperator.java | 32 +-
.../process/SlidingWindowAggregationOperator.java | 28 +
.../operator/process/TagAggregationOperator.java | 233 +++
.../process/last/UpdateLastCacheOperator.java | 2 +-
.../operator/schema/CountMergeOperator.java | 90 +-
.../operator/schema/DevicesSchemaScanOperator.java | 16 +-
.../schema/LevelTimeSeriesCountOperator.java | 50 +-
.../operator/schema/NodePathsConvertOperator.java | 2 +-
.../schema/PathsUsingTemplateScanOperator.java | 14 +-
.../operator/schema/SchemaFetchScanOperator.java | 7 +-
.../operator/schema/SchemaQueryScanOperator.java | 31 +-
.../operator/schema/SchemaTsBlockUtil.java | 57 +
.../schema/TimeSeriesSchemaScanOperator.java | 16 +-
.../AbstractSeriesAggregationScanOperator.java | 3 +-
.../AlignedSeriesAggregationScanOperator.java | 2 +-
.../operator/source/AlignedSeriesScanOperator.java | 2 +-
.../operator/source/AlignedSeriesScanUtil.java | 2 +-
.../db/mpp/execution/operator/window/IWindow.java | 66 +
.../execution/operator/window/IWindowManager.java | 91 ++
.../mpp/execution/operator/window/TimeWindow.java | 84 +
.../operator/window/TimeWindowManager.java | 133 ++
.../execution/schedule/AbstractDriverThread.java | 13 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 24 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 176 ++
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 253 +--
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 1715 +++++++++++++-------
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 34 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 70 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 108 +-
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 225 ---
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 131 --
.../mpp/plan/analyze/GroupByLevelController.java | 169 +-
.../db/mpp/plan/analyze/IPartitionFetcher.java | 42 +-
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 12 +
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 14 +-
.../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 105 ++
.../plan/analyze/StandalonePartitionFetcher.java | 5 -
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 59 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 28 +-
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +
.../db/mpp/plan/execution/QueryExecution.java | 49 +-
.../mpp/plan/execution/config/ConfigExecution.java | 9 +-
.../plan/execution/config/ConfigTaskVisitor.java | 34 +
.../config/executor/ClusterConfigTaskExecutor.java | 386 ++++-
.../config/executor/IConfigTaskExecutor.java | 13 +
.../executor/StandaloneConfigTaskExecutor.java | 79 +-
.../config/metadata/CountStorageGroupTask.java | 2 +-
.../execution/config/metadata/GetRegionIdTask.java | 76 +
.../config/metadata/GetSeriesSlotListTask.java | 77 +
.../config/metadata/GetTimeSlotListTask.java | 76 +
.../execution/config/metadata/ShowRegionTask.java | 2 +-
.../config/metadata/ShowTriggersTask.java | 97 ++
.../plan/execution/config/sys/AuthorizerTask.java | 4 +-
.../config/sys/sync/ShowPipeSinkTask.java | 27 +-
.../execution/config/sys/sync/ShowPipeTask.java | 10 +-
.../memory/StatementMemorySourceVisitor.java | 3 +-
.../mpp/plan/expression/leaf/ConstantOperand.java | 4 +-
.../plan/expression/leaf/TimeSeriesOperand.java | 11 +-
.../plan/expression/multi/FunctionExpression.java | 4 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 274 +++-
.../db/mpp/plan/parser/StatementGenerator.java | 17 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 271 +++-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 295 ++--
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 81 +-
.../db/mpp/plan/planner/SubPlanTypeExtractor.java | 11 +-
.../planner/distribution/ExchangeNodeAdder.java | 5 +
.../SimpleFragmentParallelPlanner.java | 2 +-
.../plan/planner/distribution/SourceRewriter.java | 91 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 31 +
.../db/mpp/plan/planner/plan/node/PlanNode.java | 2 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/load/LoadSingleTsFileNode.java | 171 +-
.../planner/plan/node/load/LoadTsFileNode.java | 22 +-
.../plan/node/load/LoadTsFilePieceNode.java | 47 +-
.../metedata/read/NodePathsSchemaScanNode.java | 2 +-
.../node/metedata/read/SchemaFetchScanNode.java | 21 +-
.../node/metedata/write/ActivateTemplateNode.java | 17 +-
.../write/CreateAlignedTimeSeriesNode.java | 25 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 2 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 17 +-
.../write/InternalCreateTimeSeriesNode.java | 2 +-
.../metedata/write/InvalidateSchemaCacheNode.java | 2 +-
.../plan/node/metedata/write/MeasurementGroup.java | 27 +
.../plan/node/process/GroupByLevelNode.java | 21 +-
.../planner/plan/node/process/GroupByTagNode.java | 312 ++++
.../plan/node/source/AlignedLastQueryScanNode.java | 4 +-
.../source/AlignedSeriesAggregationScanNode.java | 4 +-
.../plan/node/source/AlignedSeriesScanNode.java | 4 +-
.../plan/node/source/LastQueryScanNode.java | 4 +-
.../node/source/SeriesAggregationScanNode.java | 4 +-
.../planner/plan/node/source/SeriesScanNode.java | 4 +-
.../planner/plan/node/write/DeleteDataNode.java | 11 +-
.../plan/node/write/InsertMultiTabletsNode.java | 13 +-
.../plan/planner/plan/node/write/InsertNode.java | 21 +-
.../planner/plan/node/write/InsertRowNode.java | 52 +-
.../planner/plan/node/write/InsertRowsNode.java | 19 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 19 +-
.../planner/plan/node/write/InsertTabletNode.java | 74 +-
.../plan/parameter/AggregationDescriptor.java | 4 +-
.../CrossSeriesAggregationDescriptor.java | 114 ++
.../parameter/DeviceViewIntoPathDescriptor.java | 208 +++
.../plan/parameter/GroupByLevelDescriptor.java | 114 --
.../planner/plan/parameter/IntoPathDescriptor.java | 167 ++
.../db/mpp/plan/scheduler/ClusterScheduler.java | 1 +
.../scheduler/FragmentInstanceDispatcherImpl.java | 115 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 42 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 31 +-
.../db/mpp/plan/statement/StatementVisitor.java | 21 +
.../statement/component/GroupByLevelComponent.java | 9 +-
.../statement/component/GroupByTagComponent.java | 38 +
.../plan/statement/component/HavingCondition.java | 7 +-
.../plan/statement/component/IntoComponent.java | 237 +++
.../db/mpp/plan/statement/component/IntoItem.java | 73 +
.../crud/InsertMultiTabletsStatement.java | 4 +-
.../plan/statement/crud/InsertRowStatement.java | 6 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 5 +-
.../plan/statement/crud/InsertRowsStatement.java | 4 +-
.../plan/statement/crud/InsertTabletStatement.java | 18 +-
.../plan/statement/crud/LoadTsFileStatement.java | 79 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 64 +
.../statement/internal/SchemaFetchStatement.java | 9 +-
.../metadata/DeleteTimeSeriesStatement.java | 5 +
.../statement/metadata/GetRegionIdStatement.java | 100 ++
.../metadata/GetSeriesSlotListStatement.java | 82 +
.../metadata/GetTimeSlotListStatement.java | 101 ++
.../metadata/SetStorageGroupStatement.java | 16 +
.../statement/metadata/ShowTriggersStatement.java | 52 +
.../sys/sync/CreatePipeSinkStatement.java | 2 +-
.../statement/sys/sync/CreatePipeStatement.java | 2 +-
.../dag/input/ConstantInputReader.java | 3 +-
.../transformation/dag/util/TransformUtils.java | 3 +-
.../protocol/influxdb/input/InfluxLineParser.java | 4 +-
.../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 8 +-
.../protocol/mpprest/handler/ExceptionHandler.java | 13 +-
.../mpprest/impl/GrafanaApiServiceImpl.java | 9 +-
.../protocol/mpprest/impl/RestApiServiceImpl.java | 21 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 75 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 2 +-
.../iotdb/db/qp/logical/sys/LoadFilesOperator.java | 14 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 2 +-
.../db/qp/physical/crud/GroupByTimeFillPlan.java | 6 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 2 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 2 +-
.../sys/ActivateTemplateInClusterPlan.java | 19 +-
.../db/qp/physical/sys/ActivateTemplatePlan.java | 8 +-
.../qp/physical/sys/AutoCreateDeviceMNodePlan.java | 8 +-
.../iotdb/db/qp/physical/sys/ChangeAliasPlan.java | 3 +-
.../db/qp/physical/sys/ChangeTagOffsetPlan.java | 3 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 38 +-
.../qp/physical/sys/CreateContinuousQueryPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/CreatePipePlan.java | 2 +-
.../db/qp/physical/sys/CreatePipeSinkPlan.java | 2 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 3 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 8 +-
.../iotdb/db/qp/physical/sys/OperateFilePlan.java | 9 +-
.../qp/physical/sys/PreDeleteTimeSeriesPlan.java | 5 +-
.../sys/RollbackPreDeleteTimeSeriesPlan.java | 6 +-
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 3 +-
.../db/qp/physical/sys/UnsetTemplatePlan.java | 3 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 111 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 5 +-
.../apache/iotdb/db/qp/utils/DateTimeUtils.java | 757 +++++++++
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 742 ---------
.../iotdb/db/qp/utils/GroupByLevelController.java | 2 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 10 +-
.../iotdb/db/query/context/QueryContext.java | 63 +-
.../iotdb/db/query/control/SessionManager.java | 8 +-
.../db/query/control/SessionTimeoutManager.java | 12 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 2 +-
.../query/dataset/groupby/GroupByTimeDataSet.java | 2 +-
.../groupby/GroupByWithValueFilterDataSet.java | 4 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 4 +-
.../db/query/executor/AggregationExecutor.java | 4 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 2 +-
.../db/query/executor/RawDataQueryExecutor.java | 4 +-
.../iotdb/db/query/executor/UDFQueryExecutor.java | 2 +-
.../executor/fill/AlignedLastPointReader.java | 2 +-
.../apache/iotdb/db/query/executor/fill/IFill.java | 2 +-
.../iotdb/db/query/executor/fill/LinearFill.java | 6 +-
.../iotdb/db/query/executor/fill/PreviousFill.java | 4 +-
.../groupby/impl/LocalAlignedGroupByExecutor.java | 2 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 4 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 2 +-
.../series/AlignedSeriesAggregateReader.java | 2 +-
.../query/reader/series/AlignedSeriesReader.java | 2 +-
.../query/timegenerator/ServerTimeGenerator.java | 2 +-
.../iotdb/db/rescon/PrimitiveArrayManager.java | 3 +
.../org/apache/iotdb/db/rescon/SystemInfo.java | 76 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 198 ++-
.../db/service/DataNodeServerCommandLine.java | 145 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 6 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 2 +
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 5 +-
.../iotdb/db/service/RegionMigrateService.java | 8 +-
.../db/service/ResourcesInformationHolder.java | 43 +
.../db/service/metrics/predefined/FileMetrics.java | 61 +-
.../service/metrics/predefined/SystemMetrics.java | 46 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 63 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 357 +++-
.../service/thrift/impl/DataNodeRegionManager.java | 150 +-
.../db/service/thrift/impl/TSServiceImpl.java | 5 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 363 +++--
.../db/sync/common/ClusterSyncInfoFetcher.java | 139 ++
.../iotdb/db/sync/common/ISyncInfoFetcher.java | 20 +-
.../apache/iotdb/db/sync/common/LocalSyncInfo.java | 152 ++
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 112 +-
.../org/apache/iotdb/db/sync/common/SyncInfo.java | 264 ---
.../db/sync/common/persistence/SyncLogReader.java | 128 --
.../db/sync/common/persistence/SyncLogWriter.java | 135 --
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 694 +++++---
.../iotdb/db/sync/externalpipe/ExtPipePlugin.java | 31 +-
.../externalpipe/operation/InsertOperation.java | 2 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 2 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 4 +-
.../db/sync/receiver/load/DeletionLoader.java | 2 +-
.../iotdb/db/sync/receiver/load/ILoader.java | 2 +-
.../iotdb/db/sync/receiver/load/SchemaLoader.java | 2 +-
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 3 +-
.../db/sync/sender/pipe/ExternalPipeSink.java | 43 +-
.../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 143 --
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 21 +-
.../apache/iotdb/db/sync/sender/pipe/PipeInfo.java | 97 --
.../iotdb/db/sync/sender/pipe/PipeMessage.java | 58 -
.../apache/iotdb/db/sync/sender/pipe/PipeSink.java | 63 -
.../iotdb/db/sync/sender/pipe/PipeSinkFactory.java | 41 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 60 +-
.../iotdb/db/sync/sender/pipe/TsFilePipeInfo.java | 103 --
.../db/sync/sender/recovery/TsFilePipeLogger.java | 4 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 4 +-
.../db/sync/transport/client/SenderManager.java | 10 +-
.../sync/transport/client/SyncClientFactory.java | 6 +-
.../db/sync/transport/server/ReceiverManager.java | 6 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 6 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 6 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 6 +-
.../apache/iotdb/db/tools/schema/MLogParser.java | 122 +-
.../db/tools/watermark/WatermarkDetector.java | 4 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 53 +-
.../db/trigger/executor/TriggerFireResult.java | 57 +
.../db/trigger/executor/TriggerFireVisitor.java | 423 +++++
.../db/trigger/service/TriggerClassLoader.java | 55 +
.../trigger/service/TriggerClassLoaderManager.java | 84 +
.../trigger/service/TriggerManagementService.java | 313 +++-
.../org/apache/iotdb/db/utils/CommonUtils.java | 79 +
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 10 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 15 +-
.../iotdb/db/utils/IExpressionDeserializeUtil.java | 2 +-
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 14 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +-
.../apache/iotdb/db/utils/TimePartitionUtils.java | 41 +
.../db/utils/datastructure/AlignedTVList.java | 222 ++-
.../db/utils/datastructure/BackAlignedTVList.java | 93 ++
.../db/utils/datastructure/BackBinaryTVList.java | 90 +
.../db/utils/datastructure/BackBooleanTVList.java | 89 +
.../db/utils/datastructure/BackDoubleTVList.java | 89 +
.../db/utils/datastructure/BackFloatTVList.java | 89 +
.../db/utils/datastructure/BackIntTVList.java | 90 +
.../db/utils/datastructure/BackLongTVList.java | 89 +
.../iotdb/db/utils/datastructure/BackwardSort.java | 134 ++
.../iotdb/db/utils/datastructure/BinaryTVList.java | 89 +
.../db/utils/datastructure/BooleanTVList.java | 49 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 43 +
.../iotdb/db/utils/datastructure/FloatTVList.java | 43 +
.../iotdb/db/utils/datastructure/IntTVList.java | 32 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 43 +
.../db/utils/datastructure/QuickAlignedTVList.java | 61 +
.../db/utils/datastructure/QuickBinaryTVList.java | 56 +
.../db/utils/datastructure/QuickBooleanTVList.java | 53 +
.../db/utils/datastructure/QuickDoubleTVList.java | 53 +
.../db/utils/datastructure/QuickFloatTVList.java | 53 +
.../db/utils/datastructure/QuickIntTVList.java | 53 +
.../db/utils/datastructure/QuickLongTVList.java | 53 +
.../iotdb/db/utils/datastructure/QuickSort.java | 73 +
.../iotdb/db/utils/datastructure/TVList.java | 33 +-
.../utils/datastructure/TVListSortAlgorithm.java | 25 +
.../db/utils/datastructure/TimAlignedTVList.java | 163 --
.../db/utils/datastructure/TimBinaryTVList.java | 33 -
.../db/utils/datastructure/TimBooleanTVList.java | 33 -
.../db/utils/datastructure/TimDoubleTVList.java | 32 -
.../db/utils/datastructure/TimFloatTVList.java | 32 -
.../iotdb/db/utils/datastructure/TimIntTVList.java | 16 -
.../db/utils/datastructure/TimLongTVList.java | 32 -
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 102 +-
.../timerangeiterator/AggrWindowIterator.java | 18 +-
.../TimeRangeIteratorFactory.java | 2 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 17 +
.../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 4 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 7 +-
.../apache/iotdb/db/wal/io/WALByteBufReader.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 126 +-
.../file/AbstractTsFileRecoverPerformer.java | 8 +
.../apache/iotdb/db/conf/IoTDBStopCheckTest.java | 110 --
.../engine/compaction/AbstractCompactionTest.java | 121 +-
.../ReadPointCompactionPerformerTest.java | 1539 +++++++++++++++++-
.../cross/RewriteCompactionFileSelectorTest.java | 30 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 2 +-
.../inner/InnerCompactionMoreDataTest.java | 2 +-
.../compaction/inner/InnerSeqCompactionTest.java | 7 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 13 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 81 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 3 +-
.../SizeTieredCompactionRecoverTest.java | 2 +-
.../SizeTieredCompactionSelectorTest.java | 5 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 14 +-
.../db/engine/snapshot/IoTDBSnapshotTest.java | 13 +-
.../db/engine/storagegroup/DataRegionTest.java | 60 +-
.../storagegroup/StorageGroupProcessorTest.java | 20 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 11 +-
.../engine/storagegroup/TsFileProcessorTest.java | 6 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 6 +-
.../db/engine/storagegroup/TsFileResourceTest.java | 92 ++
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 17 +-
.../iotdb/db/metadata/SchemaAdvancedTest.java | 2 +-
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 6 +-
.../org/apache/iotdb/db/metadata/TemplateTest.java | 2 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 22 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 18 +-
.../mtree/schemafile/AliasIndexPageTest.java | 237 +++
.../mtree/schemafile/InternalPageTest.java | 222 +++
.../metadata/mtree/schemafile/RecordUtilTests.java | 21 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 290 +++-
.../metadata/mtree/schemafile/SchemaPageTest.java | 71 +-
.../db/metadata/mtree/schemafile/SegmentTest.java | 151 --
.../mtree/schemafile/WrappedSegmentTest.java | 248 +++
.../db/metadata/path/MeasurementPathTest.java | 119 ++
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 128 +-
.../plan/SchemaRegionPlanCompatibilityTest.java | 318 ++++
.../iotdb/db/mpp/aggregation/AccumulatorTest.java | 42 +-
.../common/schematree/ClusterSchemaTreeTest.java | 2 +-
.../db/mpp/common/schematree/NodeRefTest.java | 47 +
.../iotdb/db/mpp/execution/DataDriverTest.java | 2 +-
.../operator/AggregationOperatorTest.java | 2 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 2 +-
.../operator/AlignedSeriesScanOperatorTest.java | 4 +-
.../operator/DeviceMergeOperatorTest.java | 2 +-
.../execution/operator/DeviceViewOperatorTest.java | 2 +-
.../execution/operator/LastQueryOperatorTest.java | 2 +-
.../operator/LastQuerySortOperatorTest.java | 2 +-
.../mpp/execution/operator/LimitOperatorTest.java | 2 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 2 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 11 +-
.../operator/RawDataAggregationOperatorTest.java | 2 +-
.../SeriesAggregationScanOperatorTest.java | 2 +-
.../execution/operator/SeriesScanOperatorTest.java | 2 +-
.../SlidingWindowAggregationOperatorTest.java | 2 +-
.../execution/operator/TimeJoinOperatorTest.java | 2 +-
.../operator/UpdateLastCacheOperatorTest.java | 2 +-
.../operator/schema/CountMergeOperatorTest.java | 2 +
.../schema/SchemaFetchScanOperatorTest.java | 5 +-
.../plan/analyze/AggregationDescriptorTest.java | 21 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 662 +++++++-
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 295 ++++
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 153 ++
.../db/mpp/plan/parser/StatementGeneratorTest.java | 16 +
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 2 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 93 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 24 +-
.../distribution/AggregationDistributionTest.java | 28 +-
.../distribution/DistributionPlannerBasicTest.java | 6 +-
.../mpp/plan/plan/distribution/LastQueryTest.java | 4 +-
.../distribution/NoDataRegionPlanningTest.java | 2 +-
.../metadata/read/SchemaFetchScanNodeTest.java | 7 +-
.../node/process/AggregationNodeSerdeTest.java | 2 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 6 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 122 ++
.../plan/plan/node/process/LimitNodeSerdeTest.java | 2 +-
.../plan/node/process/OffsetNodeSerdeTest.java | 2 +-
.../plan/plan/node/process/SortNodeSerdeTest.java | 2 +-
.../plan/node/process/TimeJoinNodeSerdeTest.java | 2 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 2 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 2 +-
.../plan/node/write/WritePlanNodeSplitTest.java | 24 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 12 +-
.../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 116 +-
.../reader/series/SeriesAggregateReaderTest.java | 2 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 10 +-
.../DataNodeInternalRPCServiceImplTest.java | 11 +-
.../org/apache/iotdb/db/sync/SyncTestUtils.java | 8 +-
.../db/sync/datasource/PipeOpManagerTest.java | 171 +-
.../db/sync/datasource/TsFileOpBlockTest.java | 619 ++++++-
.../db/sync/persistence/LocalSyncInfoTest.java | 98 ++
.../iotdb/db/sync/persistence/SyncLogTest.java | 121 ++
.../sync/pipedata/BufferedPipeDataQueueTest.java | 4 +-
.../db/sync/receiver/manager/SyncInfoTest.java | 95 --
.../db/sync/receiver/recovery/SyncLogTest.java | 116 --
.../iotdb/db/sync/transport/SyncTransportTest.java | 6 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 17 -
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 6 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 2 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 10 +-
.../db/utils/datastructure/BinaryTVListTest.java | 38 +-
.../db/utils/datastructure/BooleanTVListTest.java | 8 +-
.../db/utils/datastructure/DoubleTVListTest.java | 12 +-
.../db/utils/datastructure/FloatTVListTest.java | 10 +-
.../db/utils/datastructure/IntTVListTest.java | 12 +-
.../db/utils/datastructure/LongTVListTest.java | 12 +-
.../db/utils/datastructure/VectorTVListTest.java | 77 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 208 ++-
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 4 +-
.../datanode1conf/iotdb-datanode.properties | 3 +-
.../resources/datanode1conf/iotdb-rest.properties | 61 +
.../datanode2conf/iotdb-datanode.properties | 4 +-
.../resources/datanode2conf/iotdb-rest.properties | 61 +
.../datanode3conf/iotdb-datanode.properties | 1 +
.../resources/datanode3conf/iotdb-rest.properties | 61 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 16 +-
.../main/java/org/apache/iotdb/session/Config.java | 51 -
.../java/org/apache/iotdb/session/ISession.java | 4 +-
.../java/org/apache/iotdb/session/Session.java | 136 +-
.../org/apache/iotdb/session/SessionConfig.java | 51 +
.../apache/iotdb/session/SessionConnection.java | 2 +-
.../org/apache/iotdb/session/SessionDataSet.java | 4 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 62 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 12 +-
site/src/main/.vuepress/config.js | 88 +-
spark-iotdb-connector/pom.xml | 4 +-
spark-tsfile/pom.xml | 4 +-
.../src/main/thrift/confignode.thrift | 263 ++-
.../src/main/thrift/mutlileader.thrift | 67 +-
thrift/src/main/thrift/client.thrift | 1 +
thrift/src/main/thrift/datanode.thrift | 92 +-
.../iotdb/trigger/api/enums/FailureStrategy.java | 37 +-
.../iotdb/trigger/api/enums/TriggerType.java | 2 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 10 +
.../tsfile/common/constant/TsFileConstant.java | 4 +
.../tsfile/file/metadata/AlignedChunkMetadata.java | 2 +-
.../file/metadata/AlignedTimeSeriesMetadata.java | 15 +
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 57 +-
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 2 +-
.../file/metadata/MetadataIndexConstructor.java | 9 +-
.../tsfile/file/metadata/MetadataIndexNode.java | 2 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 44 +
.../iotdb/tsfile/file/metadata/TsFileMetadata.java | 9 +-
.../iotdb/tsfile/read/TsFileDeviceIterator.java | 14 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 67 +
.../org/apache/iotdb/tsfile/read/common/Path.java | 18 +-
.../apache/iotdb/tsfile/read/common/TimeRange.java | 18 +-
.../tsfile/read/common/block/TsBlockUtil.java | 15 +-
.../iotdb/tsfile/read/filter/operator/Regexp.java | 48 +-
.../read/reader/chunk/AlignedChunkReader.java | 1 +
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 8 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 18 +-
.../iotdb/tsfile/utils/TsFileGeneratorUtils.java | 107 ++
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 12 +
.../apache/iotdb/tsfile/write/record/Tablet.java | 341 +++-
.../write/writer/RestorableTsFileIOWriter.java | 12 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 363 ++++-
.../write/writer/tsmiterator/DiskTSMIterator.java | 132 ++
.../write/writer/tsmiterator/TSMIterator.java | 147 ++
.../tsfile/file/metadata/ChunkMetadataTest.java | 70 +
.../iotdb/tsfile/read/common/TimeRangeTest.java | 19 +
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 15 +-
.../tsfile/write/TsFileIntegrityCheckingTool.java | 251 +++
.../iotdb/tsfile/write/record/TabletTest.java | 65 +
.../writer/TsFileIOWriterMemoryControlTest.java | 1303 +++++++++++++++
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 4 +-
1206 files changed, 69664 insertions(+), 33387 deletions(-)
[iotdb] 06/13: fix
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 ae95d7561db17a328ccd7fb6eecb957a742fcdea
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Sep 19 11:30:31 2022 +0800
fix
---
.github/workflows/client-python.yml | 1 +
1 file changed, 1 insertion(+)
diff --git a/.github/workflows/client-python.yml b/.github/workflows/client-python.yml
index 195c951893..1586e0c53b 100644
--- a/.github/workflows/client-python.yml
+++ b/.github/workflows/client-python.yml
@@ -57,6 +57,7 @@ jobs:
docker run -d -p 22278:22278 -p 22277:22277 iotdb:confignode
docker ps
docker build . -f docker/src/main/Dockerfile-datanode -t "iotdb:dev"
+ docker run -d -p 6667:6667 -p 8777:8777 -p 22277:22277 -p 9003:9003 -p 40010:40010 -p 50010:50010 iotdb:dev
docker images
docker ps
- name: Install IoTDB python client requirements
[iotdb] 09/13: fix
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 2446aefa244483ed65383559fa6ea6eb0ebe161b
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Sep 19 14:43:03 2022 +0800
fix
---
.github/workflows/client-python.yml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/.github/workflows/client-python.yml b/.github/workflows/client-python.yml
index 230f9a29c5..9fb748fdaf 100644
--- a/.github/workflows/client-python.yml
+++ b/.github/workflows/client-python.yml
@@ -5,7 +5,7 @@ name: Python Client
on:
push:
branches:
- - master
+ - 1c1d_dockertest
- 'rel/*'
- "new_*"
paths-ignore:
[iotdb] 01/13: test
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 65a80b6d8dc653f28735ade395beac45a30ecc47
Author: HTHou <hh...@outlook.com>
AuthorDate: Sun Sep 18 00:16:33 2022 +0800
test
---
.github/workflows/client-python.yml | 4 +--
docker/src/main/Dockerfile-1c1d | 50 +++++++++++++++++++++++++++++++++++++
2 files changed, 52 insertions(+), 2 deletions(-)
diff --git a/.github/workflows/client-python.yml b/.github/workflows/client-python.yml
index 230f9a29c5..c92cd9f4ae 100644
--- a/.github/workflows/client-python.yml
+++ b/.github/workflows/client-python.yml
@@ -5,7 +5,7 @@ name: Python Client
on:
push:
branches:
- - master
+ - 1c1d_dockertest
- 'rel/*'
- "new_*"
paths-ignore:
@@ -53,7 +53,7 @@ jobs:
run: mvn -B clean install -pl distribution,client-py -am -DskipTests
- name: Build IoTDB server docker image
run: |
- docker build . -f docker/src/main/Dockerfile-single -t "iotdb:dev"
+ docker build . -f docker/src/main/Dockerfile-1c1d -t "iotdb:dev"
docker images
- name: Install IoTDB python client requirements
run: pip3 install -r client-py/requirements_dev.txt
diff --git a/docker/src/main/Dockerfile-1c1d b/docker/src/main/Dockerfile-1c1d
new file mode 100644
index 0000000000..95b9d69b41
--- /dev/null
+++ b/docker/src/main/Dockerfile-1c1d
@@ -0,0 +1,50 @@
+#
+# 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 /
+
+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 \
+ && apt remove unzip -y \
+ && apt autoremove -y \
+ && apt purge --auto-remove -y \
+ && apt clean -y \
+RUN dos2unix /iotdb/confignode/sbin/start-confignode.sh
+RUN dos2unix /iotdb/confignode/sbin/../conf/confignode-env.sh
+RUN dos2unix /iotdb/datanode/sbin/start-datanode.sh
+RUN dos2unix /iotdb/datanode/sbin/../conf/datanode-env.sh
+EXPOSE 6667
+EXPOSE 31999
+EXPOSE 5555
+EXPOSE 8086
+EXPOSE 8181
+VOLUME /iotdb/confignode/data
+VOLUME /iotdb/confignode/logs
+VOLUME /iotdb/datanode/data
+VOLUME /iotdb/datanode/logs
+ENV PATH="/iotdb/confignode/sbin/:/iotdb/datanode/sbin/:/iotdb/tools/:${PATH}"
+CMD ["/iotdb/confignode/sbin/start-confignode.sh"]
+ENTRYPOINT ["/iotdb/datanode/sbin/start-datanode.sh"]
[iotdb] 04/13: fix
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 7d27c91fe03f41418e13ea626095594403129596
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Sep 19 11:07:41 2022 +0800
fix
---
.github/workflows/client-python.yml | 1 +
1 file changed, 1 insertion(+)
diff --git a/.github/workflows/client-python.yml b/.github/workflows/client-python.yml
index a7833c7b60..d343a5b522 100644
--- a/.github/workflows/client-python.yml
+++ b/.github/workflows/client-python.yml
@@ -54,6 +54,7 @@ jobs:
- name: Build IoTDB server docker image
run: |
docker build . -f docker/src/main/Dockerfile-confignode -t "iotdb:confignode"
+ docker run -d -p 22278:22278 -p 22277:22277 iotdb:confignode
docker build . -f docker/src/main/Dockerfile-datanode -t "iotdb:dev"
docker images
- name: Install IoTDB python client requirements
[iotdb] 08/13: fix
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 e202302babc48b0d084472b3d18d5d9cfd93291c
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Sep 19 14:38:17 2022 +0800
fix
---
.github/workflows/client-python.yml | 9 ++-------
docker/src/main/Dockerfile-single | 4 ++--
2 files changed, 4 insertions(+), 9 deletions(-)
diff --git a/.github/workflows/client-python.yml b/.github/workflows/client-python.yml
index cfbe69fa1f..230f9a29c5 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:
@@ -53,13 +53,8 @@ jobs:
run: mvn -B clean install -pl distribution,client-py -am -DskipTests
- name: Build IoTDB server docker image
run: |
- docker build . -f docker/src/main/Dockerfile-confignode -t "iotdb:confignode"
- docker run -d -p 22278:22278 -p 22277:22277 iotdb:confignode
- docker ps
- docker build . -f docker/src/main/Dockerfile-datanode -t "iotdb:dev"
- docker run -d -p 6667:6667 -p 8777:8777 -p 9003:9003 -p 40010:40010 -p 50010:50010 iotdb:dev
+ docker build . -f docker/src/main/Dockerfile-single -t "iotdb:dev"
docker images
- docker ps
- name: Install IoTDB python client requirements
run: pip3 install -r client-py/requirements_dev.txt
- name: Integration test
diff --git a/docker/src/main/Dockerfile-single b/docker/src/main/Dockerfile-single
index 3c1629cd86..ea929d3b6e 100644
--- a/docker/src/main/Dockerfile-single
+++ b/docker/src/main/Dockerfile-single
@@ -32,7 +32,7 @@ RUN apt update \
&& apt autoremove -y \
&& apt purge --auto-remove -y \
&& apt clean -y
-RUN dos2unix /iotdb/sbin/start-server.sh
+RUN dos2unix /iotdb/sbin/start-new-server.sh
RUN dos2unix /iotdb/sbin/../conf/datanode-env.sh
EXPOSE 6667
EXPOSE 31999
@@ -42,4 +42,4 @@ EXPOSE 8181
VOLUME /iotdb/data
VOLUME /iotdb/logs
ENV PATH="/iotdb/sbin/:/iotdb/tools/:${PATH}"
-ENTRYPOINT ["/iotdb/sbin/start-server.sh"]
+ENTRYPOINT ["/iotdb/sbin/start-new-server.sh"]
[iotdb] 03/13: fix
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 00d455cfc54d7d2f31166b95b3165ea63aaf77c1
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Sep 19 09:53:37 2022 +0800
fix
---
docker/src/main/Dockerfile-confignode | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docker/src/main/Dockerfile-confignode b/docker/src/main/Dockerfile-confignode
index 818a233c6d..0ba8afa1c5 100644
--- a/docker/src/main/Dockerfile-confignode
+++ b/docker/src/main/Dockerfile-confignode
@@ -38,5 +38,5 @@ EXPOSE 22278
EXPOSE 22277
VOLUME /confignode/data
VOLUME /confignode/logs
-ENV PATH="/datanode/sbin/:${PATH}"
+ENV PATH="/confignode/sbin/:${PATH}"
ENTRYPOINT ["/confignode/sbin/start-confignode.sh"]
[iotdb] 02/13: confignode
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 3de005e13b93b354c0390d6c7e7f8ea8ed1e15b7
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Sep 19 09:24:03 2022 +0800
confignode
---
.github/workflows/client-python.yml | 3 ++-
.../{Dockerfile-1c1d => Dockerfile-confignode} | 30 ++++++++--------------
.../main/{Dockerfile-1c1d => Dockerfile-datanode} | 29 ++++++++++-----------
3 files changed, 27 insertions(+), 35 deletions(-)
diff --git a/.github/workflows/client-python.yml b/.github/workflows/client-python.yml
index c92cd9f4ae..a7833c7b60 100644
--- a/.github/workflows/client-python.yml
+++ b/.github/workflows/client-python.yml
@@ -53,7 +53,8 @@ jobs:
run: mvn -B clean install -pl distribution,client-py -am -DskipTests
- name: Build IoTDB server docker image
run: |
- docker build . -f docker/src/main/Dockerfile-1c1d -t "iotdb:dev"
+ docker build . -f docker/src/main/Dockerfile-confignode -t "iotdb:confignode"
+ docker build . -f docker/src/main/Dockerfile-datanode -t "iotdb:dev"
docker images
- name: Install IoTDB python client requirements
run: pip3 install -r client-py/requirements_dev.txt
diff --git a/docker/src/main/Dockerfile-1c1d b/docker/src/main/Dockerfile-confignode
similarity index 61%
copy from docker/src/main/Dockerfile-1c1d
copy to docker/src/main/Dockerfile-confignode
index 95b9d69b41..818a233c6d 100644
--- a/docker/src/main/Dockerfile-1c1d
+++ b/docker/src/main/Dockerfile-confignode
@@ -21,30 +21,22 @@
FROM openjdk:11-jre-slim
-ADD distribution/target/apache-iotdb-*-all-bin.zip /
+ADD distribution/target/apache-iotdb-*-confignode-bin.zip /
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 /apache-iotdb-* /confignode \
&& apt remove unzip -y \
&& apt autoremove -y \
&& apt purge --auto-remove -y \
- && apt clean -y \
-RUN dos2unix /iotdb/confignode/sbin/start-confignode.sh
-RUN dos2unix /iotdb/confignode/sbin/../conf/confignode-env.sh
-RUN dos2unix /iotdb/datanode/sbin/start-datanode.sh
-RUN dos2unix /iotdb/datanode/sbin/../conf/datanode-env.sh
-EXPOSE 6667
-EXPOSE 31999
-EXPOSE 5555
-EXPOSE 8086
-EXPOSE 8181
-VOLUME /iotdb/confignode/data
-VOLUME /iotdb/confignode/logs
-VOLUME /iotdb/datanode/data
-VOLUME /iotdb/datanode/logs
-ENV PATH="/iotdb/confignode/sbin/:/iotdb/datanode/sbin/:/iotdb/tools/:${PATH}"
-CMD ["/iotdb/confignode/sbin/start-confignode.sh"]
-ENTRYPOINT ["/iotdb/datanode/sbin/start-datanode.sh"]
+ && apt clean -y
+RUN dos2unix /confignode/sbin/start-confignode.sh
+RUN dos2unix /confignode/sbin/../conf/confignode-env.sh
+EXPOSE 22278
+EXPOSE 22277
+VOLUME /confignode/data
+VOLUME /confignode/logs
+ENV PATH="/datanode/sbin/:${PATH}"
+ENTRYPOINT ["/confignode/sbin/start-confignode.sh"]
diff --git a/docker/src/main/Dockerfile-1c1d b/docker/src/main/Dockerfile-datanode
similarity index 64%
rename from docker/src/main/Dockerfile-1c1d
rename to docker/src/main/Dockerfile-datanode
index 95b9d69b41..08bba55cac 100644
--- a/docker/src/main/Dockerfile-1c1d
+++ b/docker/src/main/Dockerfile-datanode
@@ -21,30 +21,29 @@
FROM openjdk:11-jre-slim
-ADD distribution/target/apache-iotdb-*-all-bin.zip /
+ADD distribution/target/apache-iotdb-*-datanode-bin.zip /
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 /apache-iotdb-* /datanode \
&& apt remove unzip -y \
&& apt autoremove -y \
&& apt purge --auto-remove -y \
- && apt clean -y \
-RUN dos2unix /iotdb/confignode/sbin/start-confignode.sh
-RUN dos2unix /iotdb/confignode/sbin/../conf/confignode-env.sh
-RUN dos2unix /iotdb/datanode/sbin/start-datanode.sh
-RUN dos2unix /iotdb/datanode/sbin/../conf/datanode-env.sh
+ && apt clean -y
+RUN dos2unix /datanode/sbin/start-datanode.sh
+RUN dos2unix /datanode/sbin/../conf/datanode-env.sh
EXPOSE 6667
EXPOSE 31999
-EXPOSE 5555
EXPOSE 8086
EXPOSE 8181
-VOLUME /iotdb/confignode/data
-VOLUME /iotdb/confignode/logs
-VOLUME /iotdb/datanode/data
-VOLUME /iotdb/datanode/logs
-ENV PATH="/iotdb/confignode/sbin/:/iotdb/datanode/sbin/:/iotdb/tools/:${PATH}"
-CMD ["/iotdb/confignode/sbin/start-confignode.sh"]
-ENTRYPOINT ["/iotdb/datanode/sbin/start-datanode.sh"]
+EXPOSE 8777
+EXPOSE 9003
+EXPOSE 40010
+EXPOSE 50010
+EXPOSE 22277
+VOLUME /datanode/data
+VOLUME /datanode/logs
+ENV PATH="/datanode/sbin/:/datanode/tools/:${PATH}"
+ENTRYPOINT ["/datanode/sbin/start-datanode.sh"]
[iotdb] 05/13: fix
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 bf6654feb55334840c7a2a8eba7fcbe9c6d633e1
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Sep 19 11:19:12 2022 +0800
fix
---
.github/workflows/client-python.yml | 2 ++
1 file changed, 2 insertions(+)
diff --git a/.github/workflows/client-python.yml b/.github/workflows/client-python.yml
index d343a5b522..195c951893 100644
--- a/.github/workflows/client-python.yml
+++ b/.github/workflows/client-python.yml
@@ -55,8 +55,10 @@ jobs:
run: |
docker build . -f docker/src/main/Dockerfile-confignode -t "iotdb:confignode"
docker run -d -p 22278:22278 -p 22277:22277 iotdb:confignode
+ docker ps
docker build . -f docker/src/main/Dockerfile-datanode -t "iotdb:dev"
docker images
+ docker ps
- name: Install IoTDB python client requirements
run: pip3 install -r client-py/requirements_dev.txt
- name: Integration test
[iotdb] 07/13: fix
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 a8981c6fc9f0b11fcadeccb5fa2a23e54c9e9482
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Sep 19 11:38:31 2022 +0800
fix
---
.github/workflows/client-python.yml | 2 +-
docker/src/main/Dockerfile-datanode | 1 -
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git a/.github/workflows/client-python.yml b/.github/workflows/client-python.yml
index 1586e0c53b..cfbe69fa1f 100644
--- a/.github/workflows/client-python.yml
+++ b/.github/workflows/client-python.yml
@@ -57,7 +57,7 @@ jobs:
docker run -d -p 22278:22278 -p 22277:22277 iotdb:confignode
docker ps
docker build . -f docker/src/main/Dockerfile-datanode -t "iotdb:dev"
- docker run -d -p 6667:6667 -p 8777:8777 -p 22277:22277 -p 9003:9003 -p 40010:40010 -p 50010:50010 iotdb:dev
+ docker run -d -p 6667:6667 -p 8777:8777 -p 9003:9003 -p 40010:40010 -p 50010:50010 iotdb:dev
docker images
docker ps
- name: Install IoTDB python client requirements
diff --git a/docker/src/main/Dockerfile-datanode b/docker/src/main/Dockerfile-datanode
index 08bba55cac..82e36eb87b 100644
--- a/docker/src/main/Dockerfile-datanode
+++ b/docker/src/main/Dockerfile-datanode
@@ -42,7 +42,6 @@ EXPOSE 8777
EXPOSE 9003
EXPOSE 40010
EXPOSE 50010
-EXPOSE 22277
VOLUME /datanode/data
VOLUME /datanode/logs
ENV PATH="/datanode/sbin/:/datanode/tools/:${PATH}"
[iotdb] 11/13: fix
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 5353c0ac79a6a6d884250c8eaf7f01012f8cce6a
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Sep 19 15:49:11 2022 +0800
fix
---
client-py/requirements.txt | 6 ++---
client-py/requirements_dev.txt | 10 ++++----
docker/src/main/Dockerfile-confignode | 42 ------------------------------
docker/src/main/Dockerfile-datanode | 48 -----------------------------------
4 files changed, 8 insertions(+), 98 deletions(-)
diff --git a/client-py/requirements.txt b/client-py/requirements.txt
index 83cf2c3aec..521bb7ed83 100644
--- a/client-py/requirements.txt
+++ b/client-py/requirements.txt
@@ -19,8 +19,8 @@
# Pandas Export
pandas>=1.3.5
# Testcontainer
-testcontainers>=3.3.0
+testcontainers==3.3.0
numpy>=1.21.4
# SQLAlchemy Dialect
-sqlalchemy>=1.3.20
-sqlalchemy-utils>=0.36.8
\ No newline at end of file
+sqlalchemy == 1.3.20
+sqlalchemy-utils == 0.36.8
\ No newline at end of file
diff --git a/client-py/requirements_dev.txt b/client-py/requirements_dev.txt
index c470e45e53..824831a319 100644
--- a/client-py/requirements_dev.txt
+++ b/client-py/requirements_dev.txt
@@ -18,10 +18,10 @@
-r requirements.txt
# Pytest to run tests
-pytest>=6.2.2
+pytest==6.2.2
thrift==0.14.1
-flake8>=3.9.0
-black>=20.8b1
+flake8==3.9.0
+black==20.8b1
# For releases
-twine>=3.4.1
-wheel>=0.36.2
\ No newline at end of file
+twine==3.4.1
+wheel==0.36.2
\ No newline at end of file
diff --git a/docker/src/main/Dockerfile-confignode b/docker/src/main/Dockerfile-confignode
deleted file mode 100644
index 0ba8afa1c5..0000000000
--- a/docker/src/main/Dockerfile-confignode
+++ /dev/null
@@ -1,42 +0,0 @@
-#
-# 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-*-confignode-bin.zip /
-
-RUN apt update \
- && apt install lsof dos2unix procps unzip -y \
- && unzip /apache-iotdb-*-bin.zip -d / \
- && rm /apache-iotdb-*-bin.zip \
- && mv /apache-iotdb-* /confignode \
- && apt remove unzip -y \
- && apt autoremove -y \
- && apt purge --auto-remove -y \
- && apt clean -y
-RUN dos2unix /confignode/sbin/start-confignode.sh
-RUN dos2unix /confignode/sbin/../conf/confignode-env.sh
-EXPOSE 22278
-EXPOSE 22277
-VOLUME /confignode/data
-VOLUME /confignode/logs
-ENV PATH="/confignode/sbin/:${PATH}"
-ENTRYPOINT ["/confignode/sbin/start-confignode.sh"]
diff --git a/docker/src/main/Dockerfile-datanode b/docker/src/main/Dockerfile-datanode
deleted file mode 100644
index 82e36eb87b..0000000000
--- a/docker/src/main/Dockerfile-datanode
+++ /dev/null
@@ -1,48 +0,0 @@
-#
-# 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-*-datanode-bin.zip /
-
-RUN apt update \
- && apt install lsof dos2unix procps unzip -y \
- && unzip /apache-iotdb-*-bin.zip -d / \
- && rm /apache-iotdb-*-bin.zip \
- && mv /apache-iotdb-* /datanode \
- && apt remove unzip -y \
- && apt autoremove -y \
- && apt purge --auto-remove -y \
- && apt clean -y
-RUN dos2unix /datanode/sbin/start-datanode.sh
-RUN dos2unix /datanode/sbin/../conf/datanode-env.sh
-EXPOSE 6667
-EXPOSE 31999
-EXPOSE 8086
-EXPOSE 8181
-EXPOSE 8777
-EXPOSE 9003
-EXPOSE 40010
-EXPOSE 50010
-VOLUME /datanode/data
-VOLUME /datanode/logs
-ENV PATH="/datanode/sbin/:/datanode/tools/:${PATH}"
-ENTRYPOINT ["/datanode/sbin/start-datanode.sh"]