This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch insertValidate in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2328fd7b9c290292ccf384fc47810c7b7b6c3c5d Merge: 5c0f9293f0 d7cf590774 Author: HTHou <[email protected]> AuthorDate: Tue Jun 14 16:02:01 2022 +0800 Merge branch 'master' of https://github.com/apache/iotdb into insertValidate .github/workflows/cluster-it.yml | 14 +- .../resources/conf/iotdb-confignode.properties | 6 - ...lientPool.java => AsyncDataNodeClientPool.java} | 12 +- ...ientPool.java => SyncConfigNodeClientPool.java} | 55 +- ...ClientPool.java => SyncDataNodeClientPool.java} | 12 +- .../iotdb/confignode/conf/ConfigNodeConf.java | 28 +- .../confignode/conf/ConfigNodeDescriptor.java | 9 - .../confignode/conf/ConfigNodeStartupCheck.java | 100 +- .../consensus/request/ConfigRequest.java | 6 +- .../consensus/request/ConfigRequestType.java | 2 +- ...rConfigNodeReq.java => ApplyConfigNodeReq.java} | 12 +- .../iotdb/confignode/manager/ConfigManager.java | 97 +- .../iotdb/confignode/manager/ConsensusManager.java | 38 +- .../apache/iotdb/confignode/manager/Manager.java | 8 + .../iotdb/confignode/manager/NodeManager.java | 190 ++- .../iotdb/confignode/manager/PartitionManager.java | 4 +- .../confignode/manager/PermissionManager.java | 4 +- .../iotdb/confignode/manager/UDFManager.java | 6 +- .../iotdb/confignode/manager/load/LoadManager.java | 6 +- .../iotdb/confignode/persistence/NodeInfo.java | 12 +- .../executor/ConfigRequestExecutor.java | 6 +- .../procedure/env/ConfigNodeProcedureEnv.java | 6 +- .../iotdb/confignode/service/ConfigNode.java | 10 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 23 +- .../consensus/request/ConfigRequestSerDeTest.java | 10 +- .../iotdb/confignode/persistence/NodeInfoTest.java | 5 +- integration-test/README.md | 27 +- .../org/apache/iotdb/it/env/ClusterEnvBase.java | 111 +- .../java/org/apache/iotdb/it/env/ConfigNode.java | 15 +- .../java/org/apache/iotdb/it/env/DataNode.java | 13 +- .../java/org/apache/iotdb/it/env/EnvFactory.java | 2 + .../itbase/runtime/ClusterResultSetMetaData.java | 239 ++++ .../itbase/runtime/ClusterTestConnection.java | 333 ++++++ .../iotdb/itbase/runtime/ClusterTestResultSet.java | 1230 ++++++++++++++++++++ .../iotdb/itbase/runtime/ClusterTestStatement.java | 297 +++++ .../itbase/runtime/InconsistentDataException.java | 17 +- .../iotdb/itbase/runtime/NodeConnection.java | 85 ++ .../itbase/runtime/ParallelRequestDelegate.java | 60 + .../iotdb/itbase/runtime/RequestDelegate.java | 86 ++ .../iotdb/itbase/runtime/RequestThreadPool.java | 49 + .../itbase/runtime/SerialRequestDelegate.java | 45 +- metrics/pom.xml | 41 + .../org/apache/iotdb/commons/utils/AuthUtils.java | 22 + .../apache/iotdb/db/auth/AuthorizerManager.java | 19 +- .../iotdb/db/auth/ClusterAuthorityFetcher.java | 64 +- .../apache/iotdb/db/auth/IAuthorityFetcher.java | 9 +- .../iotdb/db/auth/StandaloneAuthorityFetcher.java | 20 +- ...ConfigNodeClient.java => ConfigNodeClient.java} | 78 +- .../iotdb/db/client/DataNodeClientPoolFactory.java | 10 +- .../iotdb/db/localconfignode/LocalConfigNode.java | 74 +- .../execution/datatransfer/DataBlockManager.java | 108 +- .../execution/datatransfer/LocalSinkHandle.java | 8 +- .../execution/datatransfer/LocalSourceHandle.java | 46 +- .../db/mpp/execution/datatransfer/SinkHandle.java | 36 +- .../mpp/execution/datatransfer/SourceHandle.java | 134 +-- .../execution/schedule/AbstractDriverThread.java | 13 +- .../db/mpp/execution/schedule/DriverScheduler.java | 4 +- .../mpp/execution/schedule/DriverTaskThread.java | 71 +- .../org/apache/iotdb/db/mpp/plan/Coordinator.java | 8 +- .../mpp/plan/analyze/ClusterPartitionFetcher.java | 25 +- .../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 36 +- .../db/mpp/plan/execution/QueryExecution.java | 24 +- .../mpp/plan/execution/config/AuthorizerTask.java | 67 +- .../mpp/plan/execution/config/ConfigExecution.java | 27 +- .../execution/config/CountStorageGroupTask.java | 52 +- .../plan/execution/config/CreateFunctionTask.java | 75 +- .../execution/config/DeleteStorageGroupTask.java | 70 +- .../plan/execution/config/DropFunctionTask.java | 66 +- .../db/mpp/plan/execution/config/FlushTask.java | 42 +- .../db/mpp/plan/execution/config/IConfigTask.java | 7 +- .../plan/execution/config/SetStorageGroupTask.java | 68 +- .../db/mpp/plan/execution/config/SetTTLTask.java | 58 +- .../mpp/plan/execution/config/ShowClusterTask.java | 66 +- .../plan/execution/config/ShowFunctionsTask.java | 7 +- .../execution/config/ShowStorageGroupTask.java | 65 +- .../db/mpp/plan/execution/config/ShowTTLTask.java | 86 +- .../config/executor/ClusterConfigTaskExecutor.java | 328 ++++++ .../config/executor/IConfigTaskExecutor.java | 61 + .../executor/StandsloneConfigTaskExecutor.java | 265 +++++ .../db/mpp/plan/scheduler/ClusterScheduler.java | 12 +- .../iotdb/db/qp/physical/sys/AuthorPlan.java | 26 +- .../java/org/apache/iotdb/db/service/DataNode.java | 83 +- .../thrift/impl/DataNodeTSIServiceImpl.java | 41 +- .../db/mpp/execution/ConfigExecutionTest.java | 7 +- .../java/org/apache/iotdb/rpc/TSStatusCode.java | 7 +- .../src/main/thrift/confignode.thrift | 54 +- .../block/column/BinaryArrayColumnEncoder.java | 5 +- .../block/column/ByteArrayColumnEncoder.java | 5 +- .../read/common/block/column/ColumnEncoder.java | 9 +- .../common/block/column/ColumnEncoderFactory.java | 3 +- .../read/common/block/column/ColumnEncoding.java | 6 +- .../block/column/Int32ArrayColumnEncoder.java | 8 +- .../block/column/Int64ArrayColumnEncoder.java | 21 +- .../block/column/RunLengthColumnEncoder.java | 54 + .../block/column/RunLengthEncodedColumn.java | 2 +- .../read/common/block/column/TsBlockSerde.java | 19 +- .../common/block/BinaryArrayColumnEncoderTest.java | 8 +- .../common/block/ByteArrayColumnEncoderTest.java | 9 +- .../common/block/Int32ArrayColumnEncoderTest.java | 15 +- .../common/block/Int64ArrayColumnEncoderTest.java | 17 +- ...erTest.java => RunLengthColumnEncoderTest.java} | 75 +- 101 files changed, 4387 insertions(+), 1649 deletions(-)
