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 86b55d864d change **
add 52d2699bc8 [IOTDB-3512] Region leader during heartbeat (#6322)
add e814312089 [IOTDB-3255] Turn off MLog and Implement snapshot while
using Ratis (#6337)
add 1ab5ad3fcb [IOTDB-3504] Fix inferTypes, return value and column label
of IN/LIKE… (#6301)
add 11d234ba38 [IoTDB-3566] Add IT for UDTF Hybrid Query (#6354)
add 4275937630 fix (#6349)
add c8145715d9 Fix Cast Bug (#6355)
add 7678244ebe [IOTDB-3513] Avoid double-writing of the write ahead log
for data under RatisConsensus (#6336)
add 64b638b4b1 [IOTDB-3549] Fix delete data in new standalone (#6359)
add ddf1221b7d Optimize write and MPP framework (#6358)
add 8ecdbb15ad [IOTDB-3494] Fix Python-Client test (#6362)
add 2f486bfc90 [IOTDB-3585] Support set/getFetchSize() in IT framework
(#6364)
add 7dde745854 Update the README of the integration-test module (#6367)
add 2f0218feee [IOTDB-3522] Set heartbeat as a periodic scheduled task
(#6328)
add 1c2783cfe8 [IOTDB-3582] Fix client connections leak caused by delete
storage group (#6360)
add 05f02a63e1 [IOTDB-3536] ConfigNode : org.apache.thrift.TException:
Error in calling method flush (#6340)
add 4f3890471c fix the issue that ALTER timeseries is not correct in
NewIoTDB (#6365)
add b57604cbe6 [IOTDB-3545] Add permission and SQL relation table in doc
(#6369)
add fbb74cd83e Add comment on getLeader (#6371)
add f65514eea5 [IOTDB-3584] Snapshot unstable due to segment size (#6370)
add ff5a14a86d [IOTDB-3577] Add semantic checks for linear fill (#6372)
add 4a01899bc1 [IOTDB-3573] Fix IT test stucked by JDBC infinite network
timeout (#6361)
add 809fbf7b02 Merge master
No new revisions were added by this update.
Summary of changes:
.github/workflows/standalone-it-for-mpp.yml | 2 +-
client-py/tests/test_dataframe.py | 2 +
client-py/tests/test_one_device.py | 1 +
client-py/tests/test_tablet.py | 2 +
client-py/tests/test_todf.py | 3 +
.../resources/conf/iotdb-confignode.properties | 4 -
.../confignode/client/AsyncDataNodeClientPool.java | 20 +-
.../confignode/client/SyncDataNodeClientPool.java | 21 +-
...ionManagementHandler.java => FlushHandler.java} | 28 +-
.../client/handlers/HeartbeatHandler.java | 2 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 11 -
.../confignode/conf/ConfigNodeDescriptor.java | 5 -
.../statemachine/PartitionRegionStateMachine.java | 2 +
.../iotdb/confignode/manager/ConfigManager.java | 16 +-
.../apache/iotdb/confignode/manager/Manager.java | 3 +
.../iotdb/confignode/manager/NodeManager.java | 27 ++
.../iotdb/confignode/manager/UDFManager.java | 18 +-
.../iotdb/confignode/manager/load/LoadManager.java | 78 ++--
.../thrift/ConfigNodeRPCServiceProcessor.java | 15 +-
.../org/apache/iotdb/consensus/IConsensus.java | 2 +
.../iotdb/consensus/config/MultiLeaderConfig.java | 2 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 4 +-
.../multileader/MultiLeaderConsensus.java | 22 +-
.../multileader/MultiLeaderServerImpl.java | 6 +-
.../multileader/logdispatcher/LogDispatcher.java | 12 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 21 +
.../consensus/standalone/StandAloneConsensus.java | 6 +
.../iotdb/consensus/ratis/RatisConsensusTest.java | 4 -
.../Administration-Management/Administration.md | 288 +++++++++++--
docs/UserGuide/Query-Data/Query-Filter.md | 3 +-
docs/UserGuide/Query-Data/Select-Expression.md | 39 +-
.../Administration-Management/Administration.md | 287 +++++++++++--
docs/zh/UserGuide/Query-Data/Query-Filter.md | 3 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 38 +-
integration-test/README.md | 95 +----
integration-test/pom.xml | 466 +++++++--------------
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 31 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 18 +-
.../constant}/BuiltinAggregationFunctionEnum.java | 2 +-
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 2 +-
.../iotdb/itbase/constant/UDFTestConstant.java | 6 +-
.../iotdb/itbase/runtime/ClusterTestStatement.java | 15 +-
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 2 +
.../iotdb/db/it/udf}/IoTDBUDTFHybridQueryIT.java | 31 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 2 +
.../main/java/org/apache/iotdb/jdbc/Config.java | 3 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 11 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 13 +
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 4 +
.../schemaregion/rocksdb/mnode/RMNode.java | 7 +
.../resources/conf/iotdb-engine.properties | 10 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 26 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 10 +
.../apache/iotdb/db/engine/StorageEngineV2.java | 12 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 16 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 2 +-
.../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 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 14 +-
.../org/apache/iotdb/db/mpp/plan/StepTracker.java | 80 ++++
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 68 ++-
.../db/mpp/plan/execution/QueryExecution.java | 22 +-
.../db/mpp/plan/expression/ExpressionType.java | 4 +-
.../db/mpp/plan/expression/unary/InExpression.java | 24 +-
.../mpp/plan/expression/unary/LikeExpression.java | 6 +
.../plan/expression/unary/RegularExpression.java | 6 +
.../planner/distribution/DistributionPlanner.java | 3 -
.../db/mpp/plan/scheduler/ClusterScheduler.java | 32 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 21 +-
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 63 +--
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 7 +-
.../dag/input/ConstantInputReader.java | 2 +-
.../dag/transformer/unary/InTransformer.java | 36 +-
.../dag/transformer/unary/RegularTransformer.java | 6 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 14 +-
.../service/thrift/impl/InternalServiceImpl.java | 31 +-
.../iotdb/db/wal/recover/WALRecoverManager.java | 20 +-
.../db/metadata/schemaRegion/SchemaRegionTest.java | 70 +++-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 9 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 2 +
...piServiceIT.java => GrafanaApiServiceTest.java} | 2 +-
...estServiceIT.java => IoTDBRestServiceTest.java} | 2 +-
.../org/apache/iotdb/db/script/EnvScriptIT.java | 1 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 3 +
.../db/wal/recover/WALRecoverManagerTest.java | 2 +
server/src/test/resources/logback-test.xml | 1 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 +
thrift-commons/src/main/thrift/common.thrift | 12 +-
thrift/src/main/thrift/mpp.thrift | 13 +-
106 files changed, 2233 insertions(+), 937 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/{FunctionManagementHandler.java
=> FlushHandler.java} (65%)
rename integration-test/src/{test/java/org/apache/iotdb/db/it/udf =>
main/java/org/apache/iotdb/itbase/constant}/BuiltinAggregationFunctionEnum.java
(97%)
rename integration-test/src/{test/java/org/apache/iotdb/db/it/udf =>
main/java/org/apache/iotdb/itbase/constant}/BuiltinTimeSeriesGeneratingFunctionEnum.java
(98%)
copy
integration/src/main/java/org/apache/iotdb/db/query/udf/example/ExampleUDFConstant.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/constant/UDFTestConstant.java
(91%)
copy {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it/udf}/IoTDBUDTFHybridQueryIT.java
(84%)
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
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/StepTracker.java
rename
server/src/test/java/org/apache/iotdb/db/protocol/rest/{GrafanaApiServiceIT.java
=> GrafanaApiServiceTest.java} (99%)
rename
server/src/test/java/org/apache/iotdb/db/protocol/rest/{IoTDBRestServiceIT.java
=> IoTDBRestServiceTest.java} (99%)
