This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch addAggregationIT
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 21df259f33 remove origin IoTDBAggregationLargeDataIT
add f10eed6ddb Increase the timeout (#6335)
add 7d7834c200 [IOTDB-3544] Packaging udf-api as dependency jar in build
(#6339)
add c42cfe5fbe [IOTDB-3510] Read/Write Routing policy (Routing to DataNode
with the lowest-loaded) (#6308)
add 3c88dfb6aa [IOTDB-3508] Enhance some features of the IT framework
(#6300)
add df8136d8e0 Fix new standalone auto create aligned timeseries bug
(#6345)
add 084d4a4452 [IOTDB-3541][IOTDB-3542] Support handling exception and
make it stable in cluster IT (#6341)
add 80141097f8 [IOTDB-3552] Fix fetch incorrect SchemaTree by
StandaloneSchemaFetcher bug (#6347)
add 984907e568 merge master
add 9bc70b0cf8 modify flush command
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it.yml | 10 +-
.../{cluster-it.yml => standalone-it-for-mpp.yml} | 20 +--
.../consensus/response/DataPartitionResp.java | 79 +++++++---
.../response/SchemaNodeManagementResp.java | 48 ++++--
.../consensus/response/SchemaPartitionResp.java | 59 ++++---
.../iotdb/confignode/manager/ConfigManager.java | 116 +++++++-------
.../apache/iotdb/confignode/manager/Manager.java | 24 +--
.../iotdb/confignode/manager/load/LoadManager.java | 35 +++++
.../manager/load/balancer/RouteBalancer.java | 56 +++++++
.../IRegionAllocator.java => router/IRouter.java} | 29 ++--
.../balancer/router/LoadScoreGreedyRouter.java | 80 ++++++++++
.../manager/load/heartbeat/HeartbeatCache.java | 9 +-
.../persistence/partition/PartitionInfo.java | 67 +++-----
.../partition/StorageGroupPartitionTable.java | 47 +-----
.../thrift/ConfigNodeRPCServiceProcessor.java | 38 +----
integration-test/pom.xml | 138 +++++++++++++++-
.../assembly/{cluster-test.xml => mpp-test.xml} | 0
.../env/{ClusterEnvBase.java => AbstractEnv.java} | 168 ++++++++++----------
...usterNodeBase.java => AbstractNodeWrapper.java} | 8 +-
.../java/org/apache/iotdb/it/env/Cluster1Env.java | 2 +-
.../org/apache/iotdb/it/env/ConfigFactory.java | 9 +-
.../{ConfigNode.java => ConfigNodeWrapper.java} | 4 +-
.../it/env/{DataNode.java => DataNodeWrapper.java} | 8 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 7 +-
.../env/{ClusterEnvConfig.java => MppConfig.java} | 21 +--
...emoteEnvConfig.java => RemoteServerConfig.java} | 2 +-
.../iotdb/it/env/StandaloneDataNodeWrapper.java | 36 +++--
.../apache/iotdb/it/env/StandaloneOnMppEnv.java | 56 ++++---
.../org/apache/iotdb/itbase/env/BaseConfig.java | 8 +-
.../env/{BaseNode.java => BaseNodeWrapper.java} | 2 +-
.../iotdb/itbase/runtime/ClusterTestStatement.java | 2 +-
.../itbase/runtime/ParallelRequestDelegate.java | 8 +-
.../iotdb/itbase/runtime/RequestDelegate.java | 45 +++++-
.../itbase/runtime/SerialRequestDelegate.java | 5 +-
integration-test/src/script/append-to-env.sh | 32 ++++
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 4 +-
.../it/aggregation/IoTDBAggregationDeleteIT.java | 2 +-
.../db/it/aggregation/IoTDBAggregationIT.java | 19 ++-
.../aggregation/IoTDBAggregationLargeDataIT.java | 4 +-
.../iotdb/db/it/aligned/AlignedWriteUtil.java | 7 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 2 +-
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 2 +-
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 2 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 2 +-
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 7 +
integration/checkstyle.xml | 173 ++++++++++++++++++++-
.../src/assembly/resources/sbin/stop-datanode.bat | 19 ++-
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 42 ++---
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 2 +-
udf-api/pom.xml | 29 ++++
50 files changed, 1086 insertions(+), 508 deletions(-)
copy .github/workflows/{cluster-it.yml => standalone-it-for-mpp.yml} (82%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/{region/IRegionAllocator.java
=> router/IRouter.java} (50%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LoadScoreGreedyRouter.java
rename integration-test/src/assembly/{cluster-test.xml => mpp-test.xml} (100%)
rename
integration-test/src/main/java/org/apache/iotdb/it/env/{ClusterEnvBase.java =>
AbstractEnv.java} (61%)
rename
integration-test/src/main/java/org/apache/iotdb/it/env/{ClusterNodeBase.java =>
AbstractNodeWrapper.java} (96%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{ConfigNode.java
=> ConfigNodeWrapper.java} (95%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{DataNode.java
=> DataNodeWrapper.java} (93%)
rename
integration-test/src/main/java/org/apache/iotdb/it/env/{ClusterEnvConfig.java
=> MppConfig.java} (93%)
rename
integration-test/src/main/java/org/apache/iotdb/it/env/{RemoteEnvConfig.java =>
RemoteServerConfig.java} (93%)
copy
grafana-connector/src/main/java/org/apache/iotdb/web/grafana/service/impl/DatabaseConnectServiceImpl.java
=>
integration-test/src/main/java/org/apache/iotdb/it/env/StandaloneDataNodeWrapper.java
(54%)
copy
integration/src/main/java/org/apache/iotdb/integration/env/FiveNodeCluster1Env.java
=>
integration-test/src/main/java/org/apache/iotdb/it/env/StandaloneOnMppEnv.java
(53%)
rename
integration-test/src/main/java/org/apache/iotdb/itbase/env/{BaseNode.java =>
BaseNodeWrapper.java} (96%)
create mode 100644 integration-test/src/script/append-to-env.sh
