This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch iotdb-3349
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0859e66407 Process null in DeviceViewOperator
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 52d2699bc8 [IOTDB-3512] Region leader during heartbeat (#6322)
add e814312089 [IOTDB-3255] Turn off MLog and Implement snapshot while
using Ratis (#6337)
add 76ecbba51f Merge remote-tracking branch 'origin/master' into iotdb-3349
add 35abb342dc Merge branch 'iotdb-3349' of
https://github.com/apache/iotdb into iotdb-3349
add 1d4c715ec2 delete useless log
add 833978a0a9 Merge branch 'iotdb-3349' of
https://github.com/apache/iotdb into iotdb-3349
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 +-
.../confignode/client/AsyncDataNodeClientPool.java | 2 +-
.../client/handlers/HeartbeatHandler.java | 2 +-
.../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 | 37 ++-
.../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 +--
.../org/apache/iotdb/consensus/IConsensus.java | 2 +
.../multileader/MultiLeaderConsensus.java | 5 +
.../iotdb/consensus/ratis/RatisConsensus.java | 12 +
.../consensus/standalone/StandAloneConsensus.java | 6 +
.../iotdb/consensus/ratis/RatisConsensusTest.java | 4 -
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 | 4 +-
integration-test/src/script/append-to-env.sh | 32 ++
.../org/apache/iotdb/db/it/IoTDBExampleIT.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 +++++++++-
.../schemaregion/rocksdb/mnode/RMNode.java | 7 +
.../src/assembly/resources/sbin/stop-datanode.bat | 19 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 20 +-
.../idtable/entry/InsertMeasurementMNode.java | 6 +
.../iotdb/db/metadata/logfile/MLogWriter.java | 2 +-
.../iotdb/db/metadata/mnode/EntityMNode.java | 6 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 3 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 6 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 6 +
.../db/metadata/mnode/StorageGroupEntityMNode.java | 6 +
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 6 +
.../mnode/visitor/MNodeVisitor.java} | 30 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 28 ++
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 347 +++++++++++++++++++++
.../db/metadata/mtree/store/CachedMTreeStore.java | 7 +
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 4 +
.../db/metadata/mtree/store/MemMTreeStore.java | 18 ++
.../db/metadata/schemaregion/SchemaEngine.java | 7 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 276 +++++++++-------
.../apache/iotdb/db/metadata/tag/TagManager.java | 19 ++
.../db/metadata/upgrade/MetadataUpgrader.java | 4 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 4 +-
.../operator/process/TransformOperator.java | 4 -
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 42 +--
.../dag/input/QueryDataSetInputLayer.java | 1 -
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 2 +-
.../service/thrift/impl/InternalServiceImpl.java | 31 +-
.../db/metadata/schemaRegion/SchemaRegionTest.java | 70 ++++-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 9 +-
server/src/test/resources/logback-test.xml | 1 +
thrift-commons/src/main/thrift/common.thrift | 12 +-
thrift/src/main/thrift/mpp.thrift | 13 +-
udf-api/pom.xml | 29 ++
83 files changed, 1882 insertions(+), 674 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
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/statement/metadata/DeleteTimeSeriesStatement.java
=> metadata/mnode/visitor/MNodeVisitor.java} (52%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/snapshot/MemMTreeSnapshotUtil.java
