This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/addQueryIT in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6046807cb507f30698fe86dd17bf24aba1b1242a Merge: 307fa794bb de0b507523 Author: Minghui Liu <[email protected]> AuthorDate: Sun Jun 19 11:47:50 2022 +0800 Merge remote-tracking branch 'origin/master' into lmh/addQueryIT .github/workflows/cluster-it.yml | 17 +- .../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 + .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 7 +- .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 + .../src/assembly/resources/conf/confignode-env.bat | 8 +- confignode/src/assembly/resources/conf/logback.xml | 13 +- .../consensus/request/ConfigRequest.java | 4 + .../consensus/request/ConfigRequestType.java | 3 +- .../request/read/GetRegionLocationsReq.java | 62 +++++++ .../consensus/response/RegionLocationsResp.java | 49 ++++++ .../iotdb/confignode/manager/ConfigManager.java | 14 ++ .../apache/iotdb/confignode/manager/Manager.java | 4 + .../iotdb/confignode/manager/PartitionManager.java | 5 + .../executor/ConfigRequestExecutor.java | 3 + .../persistence/partition/PartitionInfo.java | 25 +++ .../partition/StorageGroupPartitionTable.java | 39 +++++ .../thrift/ConfigNodeRPCServiceProcessor.java | 15 ++ .../consensus/request/ConfigRequestSerDeTest.java | 11 ++ .../confignode/persistence/PartitionInfoTest.java | 68 +++++++- docs/UserGuide/API/Programming-MQTT.md | 7 +- .../Maintenance-Tools/Maintenance-Command.md | 67 +++++++- docs/zh/UserGuide/API/Programming-MQTT.md | 7 +- .../Maintenance-Tools/Maintenance-Command.md | 63 +++++++ .../java/org/apache/iotdb/mqtt/MQTTClient.java | 7 + .../org/apache/iotdb/it/env/ClusterEnvBase.java | 164 ++++++++++++------ .../org/apache/iotdb/it/env/ClusterNodeBase.java | 188 ++++++++++++++------- .../java/org/apache/iotdb/it/env/ConfigNode.java | 152 ++++++++--------- .../java/org/apache/iotdb/it/env/DataNode.java | 128 ++++++-------- .../iotdb/itbase/runtime/ClusterTestStatement.java | 42 +++-- .../itbase/runtime/ParallelRequestDelegate.java | 2 +- ...gregationWithoutValueFilterWithDeletion2IT.java | 3 + ...ggregationWithoutValueFilterWithDeletionIT.java | 3 + ...upByQueryWithoutValueFilterWithDeletion2IT.java | 3 + ...oupByQueryWithoutValueFilterWithDeletionIT.java | 3 + .../apache/iotdb/commons/cluster/RegionStatus.java | 36 ++++ server/src/assembly/resources/conf/iotdb-env.bat | 8 +- server/src/assembly/resources/conf/logback.xml | 13 +- .../apache/iotdb/db/client/ConfigNodeClient.java | 28 +++ .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 + .../db/engine/compaction/CompactionScheduler.java | 6 +- .../DefaultCompactionTaskComparatorImpl.java | 17 +- .../compaction/cross/CrossSpaceCompactionTask.java | 6 +- .../compaction/inner/InnerSpaceCompactionTask.java | 6 +- .../compaction/task/AbstractCompactionTask.java | 9 +- .../db/engine/storagegroup/TsFileManager.java | 6 + .../iotdb/db/mpp/common/header/HeaderConstant.java | 24 +++ .../plan/execution/config/ConfigTaskVisitor.java | 6 + .../mpp/plan/execution/config/ShowRegionTask.java | 86 ++++++++++ .../config/executor/ClusterConfigTaskExecutor.java | 35 ++-- .../config/executor/IConfigTaskExecutor.java | 3 + .../executor/StandaloneConfigTaskExecutor.java | 14 +- .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 18 ++ .../db/mpp/plan/statement/StatementVisitor.java | 5 + .../statement/metadata/ShowRegionStatement.java | 54 ++++++ .../db/protocol/mqtt/JSONPayloadFormatter.java | 15 +- .../compaction/CompactionTaskComparatorTest.java | 74 ++++++-- .../compaction/CompactionTaskManagerTest.java | 27 ++- .../compaction/cross/CrossSpaceCompactionTest.java | 9 +- .../cross/RewriteCrossSpaceCompactionTest.java | 12 +- .../inner/InnerCompactionEmptyTsFileTest.java | 3 +- .../db/engine/storagegroup/DataRegionTest.java | 3 +- .../storagegroup/StorageGroupProcessorTest.java | 3 +- .../db/protocol/mqtt/JSONPayloadFormatterTest.java | 58 +++++++ thrift-commons/src/main/thrift/common.thrift | 10 ++ .../src/main/thrift/confignode.thrift | 14 ++ 65 files changed, 1421 insertions(+), 387 deletions(-)
