You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2023/04/20 09:00:33 UTC
[iotdb] branch lmh/FixOffsetPushDown updated (9884ec0f54 -> dedac74424)
This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/FixOffsetPushDown
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9884ec0f54 add more UTs & fix between
add a76ecfedea fix GroupByFilter
add cd94a08b2f add NotBetween & NotLike & NotRegexp
add babdd89c14 fix deserialize
add c261785bb7 fix filter
add 85d79b2819 add PredicateRemoveNotRewriter
add bf2b5381ee use PredicateRemoveNotRewriter
add 110ea55786 [IOTDB-5727] pipe task management at config node (#9533)
add 1569d17634 add a notice of time_duration function to indicate some specific situations (#9594)
add f72560bca2 [IOTDB-5570] Move heartbeat thread and statistics thread to load manager (#9608)
add 53eae3d6ef [DOC][Grafana Plugin] Update the user manual for alerting (#9622)
add d4fbe76f91 [IOTDB-5727][hotfix] Hide PipeInfo from PipeManager (#9639)
add 8b163c2f1c [IOTDB-5675] Recover template activation statistics when redoing MLog (#9571)
add 0547018b23 [IOTDB-5776]Update memory estimation of cross space compaction (#9627)
add b9fa37c912 [IOTDB-5786] Fix potential deadlock in DriverScheduler
add c97c0dc2a7 [IOTDB-5691] The first level-0 tsfile too large to trigger "Unsequence InnerSpaceComapction" and "CrossSpaceCompaction" (#9503)
add 31d3c089fa Bump jetty-server from 9.4.49.v20220914 to 9.4.51.v20230217 (#9641)
add 544a33b0a6 Fix potential Npe of ShuffleSinkHandle
add e12afecd6e [IOTDB-5735] Fix result of some UDF with align by device is incorrect (#9642)
add b02502fa14 [IOTDB-4837] Refactor Set Schema Template (#9637)
add f13699611f [IOTDB-5798] Fix concurrent problem when sinkChannel acknowledgeTsBlock() and close()
add 98adb10391 [IOTDB-5773] fix set space quota problem (#9596)
add 348763f208 Add a cache to avoid initialize duplicated device id object in write process (#9644)
add dedac74424 Merge remote-tracking branch 'origin/master' into lmh/FixOffsetPushDown
No new revisions were added by this update.
Summary of changes:
.../confignode/client/DataNodeRequestType.java | 10 +-
.../client/async/AsyncDataNodeClientPool.java | 26 +-
.../client/async/handlers/AsyncClientHandler.java | 17 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 17 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 57 +--
...ava => CheckTimeSeriesExistenceRPCHandler.java} | 47 +-
.../consensus/request/ConfigPhysicalPlan.java | 64 ++-
.../consensus/request/ConfigPhysicalPlanType.java | 37 +-
.../task/CreatePipePlanV2.java} | 41 +-
.../task/DropPipePlanV2.java} | 12 +-
.../task/SetPipeStatusPlanV2.java} | 34 +-
...PipeSinkPlan.java => CreatePipeSinkPlanV1.java} | 10 +-
.../{DropPipePlan.java => DropPipePlanV1.java} | 10 +-
...opPipeSinkPlan.java => DropPipeSinkPlanV1.java} | 10 +-
...GetPipeSinkPlan.java => GetPipeSinkPlanV1.java} | 10 +-
...reatePipePlan.java => PreCreatePipePlanV1.java} | 10 +-
.../request/write/sync/RecordPipeMessagePlan.java | 4 +-
...ipeStatusPlan.java => SetPipeStatusPlanV1.java} | 24 +-
.../{ShowPipePlan.java => ShowPipePlanV1.java} | 10 +-
.../CommitSetSchemaTemplatePlan.java} | 54 ++-
.../PreSetSchemaTemplatePlan.java} | 54 ++-
.../statemachine/ConfigRegionStateMachine.java | 9 +-
.../confignode/manager/ClusterQuotaManager.java | 18 +-
.../confignode/manager/ClusterSchemaManager.java | 84 +---
.../iotdb/confignode/manager/ConfigManager.java | 136 ++----
.../apache/iotdb/confignode/manager/IManager.java | 42 +-
.../iotdb/confignode/manager/ProcedureManager.java | 148 ++++--
.../confignode/manager/RetryFailedTasksThread.java | 85 +---
.../iotdb/confignode/manager/SyncManager.java | 306 ------------
.../iotdb/confignode/manager/load/LoadManager.java | 387 ++++++++-------
.../manager/load/balancer/RegionBalancer.java | 7 +-
.../manager/load/balancer/RouteBalancer.java | 21 +-
.../confignode/manager/load/cache/LoadCache.java | 452 +++++++++++++++++
.../cache/node}/BaseNodeCache.java | 59 +--
.../cache/node}/ConfigNodeHeartbeatCache.java | 29 +-
.../cache/node}/DataNodeHeartbeatCache.java | 25 +-
.../cache/node}/NodeHeartbeatSample.java | 7 +-
.../cache/node}/NodeStatistics.java | 11 +-
.../cache/region}/RegionCache.java | 7 +-
.../cache/region}/RegionGroupCache.java | 36 +-
.../cache/region}/RegionGroupStatistics.java | 16 +-
.../cache/region}/RegionHeartbeatSample.java | 3 +-
.../cache/region}/RegionStatistics.java | 16 +-
.../manager/load/service/HeartbeatService.java | 192 ++++++++
.../StatisticsService.java} | 210 ++------
.../iotdb/confignode/manager/node/NodeManager.java | 328 +------------
.../manager/observer/NodeStatisticsEvent.java | 2 +-
.../manager/partition/PartitionManager.java | 166 ++-----
.../manager/partition/PartitionMetrics.java | 18 +-
.../manager/partition/RegionGroupStatus.java | 21 +-
.../iotdb/confignode/manager/pipe/PipeManager.java | 12 +-
.../manager/pipe/PipePluginCoordinator.java | 8 +
.../manager/pipe/PipeTaskCoordinator.java | 73 +++
.../persistence/executor/ConfigPlanExecutor.java | 55 +--
.../confignode/persistence/node/NodeInfo.java | 47 +-
.../partition/DatabasePartitionTable.java | 62 ++-
.../persistence/partition/PartitionInfo.java | 50 +-
.../persistence/partition/RegionGroup.java | 13 +-
.../confignode/persistence/pipe/PipeInfo.java | 59 ++-
.../persistence/pipe/PipePluginInfo.java | 45 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 203 ++++++++
.../persistence/pipe/PipeTaskOperation.java | 10 +-
.../confignode/persistence/quota/QuotaInfo.java | 36 +-
.../persistence/schema/ClusterSchemaInfo.java | 96 +++-
.../persistence/schema/TemplatePreSetTable.java | 195 ++++++++
.../persistence/schema/TemplateTable.java | 1 -
.../persistence/sync/ClusterSyncInfo.java | 225 ---------
.../procedure/env/ConfigNodeProcedureEnv.java | 66 ++-
.../procedure/env/DataNodeRemoveHandler.java | 15 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 30 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 24 +-
.../pipe/task/AbstractOperatePipeProcedureV2.java | 161 +++++++
.../impl/pipe/task/CreatePipeProcedureV2.java | 275 +++++++++++
.../impl/pipe/task/DropPipeProcedureV2.java | 157 ++++++
.../impl/pipe/task/StartPipeProcedureV2.java | 177 +++++++
.../impl/pipe/task/StopPipeProcedureV2.java | 177 +++++++
.../impl/schema/DeleteDatabaseProcedure.java | 2 +-
.../impl/schema/SetTemplateProcedure.java | 534 ++++++++++++++++++++
.../impl/statemachine/RegionMigrateProcedure.java | 3 +
.../impl/sync/AbstractOperatePipeProcedure.java | 147 ------
.../procedure/impl/sync/CreatePipeProcedure.java | 131 +----
.../procedure/impl/sync/DropPipeProcedure.java | 97 +---
.../procedure/impl/sync/StartPipeProcedure.java | 136 +-----
.../procedure/impl/sync/StopPipeProcedure.java | 136 +-----
.../task/OperatePipeTaskState.java} | 13 +-
.../procedure/state/schema/SetTemplateState.java | 19 +-
.../procedure/store/ProcedureFactory.java | 22 +
.../confignode/procedure/store/ProcedureType.java | 11 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 16 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 156 ++++--
.../router/priority/GreedyPriorityTest.java | 8 +-
.../priority/LeaderPriorityBalancerTest.java | 8 +-
.../confignode/manager/node/NodeCacheTest.java | 8 +-
.../manager/partition/RegionGroupCacheTest.java | 4 +-
.../persistence/ClusterSyncInfoTest.java | 164 -------
.../iotdb/confignode/persistence/PipeInfoTest.java | 99 ++++
.../persistence/node/NodeStatisticsTest.java | 2 +-
.../statistics/RegionGroupStatisticsTest.java | 4 +-
.../partition/statistics/RegionStatisticsTest.java | 2 +-
.../{ => schema}/ClusterSchemaInfoTest.java | 3 +-
.../schema/TemplatePreSetTableTest.java | 114 +++++
.../{ => schema}/TemplateTableTest.java | 3 +-
.../CreatePipePluginProcedureTest.java | 3 +-
.../{ => plugin}/DropPipePluginProcedureTest.java | 3 +-
.../CreatePipeProcedureV2Test.java} | 33 +-
.../DropPipeProcedureV2Test.java} | 12 +-
.../StartPipeProcedureV2Test.java} | 12 +-
.../StopPipeProcedureV2Test.java} | 12 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 60 +--
docs/UserGuide/Operators-Functions/Aggregation.md | 1 +
docs/UserGuide/Reference/Common-Config-Manual.md | 11 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 68 ++-
.../UserGuide/Operators-Functions/Aggregation.md | 1 +
.../zh/UserGuide/Reference/Common-Config-Manual.md | 9 +
.../iotdb/it/env/cluster/MppCommonConfig.java | 6 +
.../it/env/cluster/MppSharedCommonConfig.java | 7 +
.../iotdb/it/env/remote/RemoteCommonConfig.java | 5 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java | 535 +++++++++++++++++++++
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 3 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 95 +++-
.../it/udf/IoTDBUDTFBuiltinScalarFunctionIT.java | 499 +++++++++++++++++--
.../iotdb/libudf/it/dprofile/DProfileIT.java | 17 +
.../resources/conf/iotdb-common.properties | 4 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 32 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +-
.../meta/ConfigNodePipePluginMetaKeeper.java | 26 +-
.../pipe/plugin/meta/PipePluginMetaKeeper.java | 22 +
.../iotdb/commons/pipe/task/meta/PipeMeta.java | 95 ++++
.../commons/pipe/task/meta/PipeMetaKeeper.java | 97 ++++
.../commons/pipe/task/meta/PipeRuntimeMeta.java | 141 ++++++
.../commons/pipe/task/meta/PipeStaticMeta.java | 170 +++++++
.../{PipeTaskMetaAccessor.java => PipeStatus.java} | 30 +-
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 98 ++++
.../iotdb/commons/sync/pipe/SyncOperation.java | 1 -
.../BuiltinTimeSeriesGeneratingFunction.java | 10 +
.../apache/iotdb/commons/path/PartialPathTest.java | 2 +-
pom.xml | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 2 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 2 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 8 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 27 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 12 +
.../estimator/AbstractCompactionEstimator.java | 6 +
.../ReadPointCrossCompactionEstimator.java | 108 +++--
.../impl/RewriteCrossSpaceCompactionSelector.java | 13 +-
.../utils/CrossCompactionTaskResource.java | 12 +
.../template/TemplateImcompatibeException.java | 14 +-
.../db/metadata/cache/DataNodeDevicePathCache.java | 69 +++
.../iotdb/db/metadata/mtree/ConfigMTree.java | 4 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 9 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 9 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 2 +-
.../db/metadata/schemaregion/SchemaEngine.java | 8 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 2 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 2 +-
.../metadata/template/ClusterTemplateManager.java | 242 +++++++++-
.../db/metadata/template/ITemplateManager.java | 7 +-
.../template/TemplateInternalRPCUpdateType.java | 17 +-
.../metadata/template/TemplateInternalRPCUtil.java | 40 +-
.../mpp/execution/exchange/sink/SinkChannel.java | 29 +-
.../operator/schema/SchemaQueryScanOperator.java | 2 +-
.../schema/source/SchemaSourceFactory.java | 5 +
.../db/mpp/execution/schedule/DriverScheduler.java | 116 +++--
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 69 +--
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 29 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 10 +-
.../db/mpp/plan/analyze/schema/ISchemaFetcher.java | 5 +-
.../plan/execution/config/ConfigTaskVisitor.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 12 +-
.../config/executor/IConfigTaskExecutor.java | 2 +-
.../metadata/template/SetSchemaTemplateTask.java | 7 +-
.../config/sys/quota/ShowSpaceQuotaTask.java | 7 +-
.../config/sys/quota/ShowThrottleQuotaTask.java | 34 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 88 ++--
.../db/mpp/plan/parser/StatementGenerator.java | 25 +-
.../plan/statement/crud/InsertRowStatement.java | 2 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 5 +-
.../v1/handler/StatementConstructionHandler.java | 5 +-
.../v2/handler/StatementConstructionHandler.java | 5 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 15 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 150 +++---
.../cross/RewriteCompactionFileSelectorTest.java | 12 +
.../cache/DataNodeDevicePathCacheTest.java | 62 +++
.../schemaRegion/SchemaRegionManagementTest.java | 4 +-
.../schema/SchemaQueryScanOperatorTest.java | 4 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 8 +-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 8 +-
.../src/main/thrift/confignode.thrift | 5 +-
thrift/src/main/thrift/datanode.thrift | 20 +-
.../iotdb/tsfile/read/filter/GroupByFilter.java | 10 +-
.../read/filter/PredicateRemoveNotRewriter.java | 50 ++
.../iotdb/tsfile/read/filter/TimeFilter.java | 154 +++---
.../iotdb/tsfile/read/filter/ValueFilter.java | 179 ++++---
.../tsfile/read/filter/basic/BinaryFilter.java | 5 -
.../iotdb/tsfile/read/filter/basic/Filter.java | 2 +
.../tsfile/read/filter/factory/FilterFactory.java | 10 +-
.../tsfile/read/filter/operator/AndFilter.java | 6 +
.../iotdb/tsfile/read/filter/operator/Between.java | 152 +++---
.../iotdb/tsfile/read/filter/operator/Eq.java | 15 +-
.../iotdb/tsfile/read/filter/operator/Gt.java | 13 +-
.../iotdb/tsfile/read/filter/operator/GtEq.java | 13 +-
.../iotdb/tsfile/read/filter/operator/In.java | 29 +-
.../iotdb/tsfile/read/filter/operator/Like.java | 50 +-
.../iotdb/tsfile/read/filter/operator/Lt.java | 13 +-
.../iotdb/tsfile/read/filter/operator/LtEq.java | 13 +-
.../iotdb/tsfile/read/filter/operator/NotEq.java | 14 +-
.../tsfile/read/filter/operator/NotFilter.java | 23 +-
.../tsfile/read/filter/operator/OrFilter.java | 6 +
.../iotdb/tsfile/read/filter/operator/Regexp.java | 52 +-
.../tsfile/read/filter/FilterSerializeTest.java | 21 +-
.../read/filter/MinTimeMaxTimeFilterTest.java | 42 +-
.../iotdb/tsfile/read/filter/OperatorTest.java | 4 +-
.../filter/PredicateRemoveNotRewriterTest.java | 122 +++++
.../tsfile/read/filter/StatisticsFilterTest.java | 47 +-
215 files changed, 8084 insertions(+), 3964 deletions(-)
rename confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{OperatePipeRPCHandler.java => CheckTimeSeriesExistenceRPCHandler.java} (52%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{sync/RecordPipeMessagePlan.java => pipe/task/CreatePipePlanV2.java} (56%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{sync/DropPipePlan.java => pipe/task/DropPipePlanV2.java} (84%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{sync/SetPipeStatusPlan.java => pipe/task/SetPipeStatusPlanV2.java} (68%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/{CreatePipeSinkPlan.java => CreatePipeSinkPlanV1.java} (87%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/{DropPipePlan.java => DropPipePlanV1.java} (88%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/{DropPipeSinkPlan.java => DropPipeSinkPlanV1.java} (87%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/{GetPipeSinkPlan.java => GetPipeSinkPlanV1.java} (87%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/{PreCreatePipePlan.java => PreCreatePipePlanV1.java} (86%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/{SetPipeStatusPlan.java => SetPipeStatusPlanV1.java} (81%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/{ShowPipePlan.java => ShowPipePlanV1.java} (88%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{sync/SetPipeStatusPlan.java => template/CommitSetSchemaTemplatePlan.java} (54%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{sync/SetPipeStatusPlan.java => template/PreSetSchemaTemplatePlan.java} (54%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/LoadCache.java
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{node/heartbeat => load/cache/node}/BaseNodeCache.java (74%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{node/heartbeat => load/cache/node}/ConfigNodeHeartbeatCache.java (80%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{node/heartbeat => load/cache/node}/DataNodeHeartbeatCache.java (80%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{node/heartbeat => load/cache/node}/NodeHeartbeatSample.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{node/heartbeat => load/cache/node}/NodeStatistics.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{partition/heartbeat => load/cache/region}/RegionCache.java (89%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{partition/heartbeat => load/cache/region}/RegionGroupCache.java (86%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{partition/heartbeat => load/cache/region}/RegionGroupStatistics.java (94%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{partition/heartbeat => load/cache/region}/RegionHeartbeatSample.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{partition/heartbeat => load/cache/region}/RegionStatistics.java (86%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/HeartbeatService.java
copy confignode/src/main/java/org/apache/iotdb/confignode/manager/load/{LoadManager.java => service/StatisticsService.java} (51%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/PipeTaskCoordinator.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java
copy node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeTaskMetaAccessor.java => confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskOperation.java (84%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/TemplatePreSetTable.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AbstractOperatePipeProcedureV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AbstractOperatePipeProcedure.java
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{sync/OperatePipeState.java => pipe/task/OperatePipeTaskState.java} (80%)
copy node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/SyncOperation.java => confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/SetTemplateState.java (79%)
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/ClusterSyncInfoTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/PipeInfoTest.java
rename confignode/src/test/java/org/apache/iotdb/confignode/persistence/{ => schema}/ClusterSchemaInfoTest.java (98%)
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/schema/TemplatePreSetTableTest.java
rename confignode/src/test/java/org/apache/iotdb/confignode/persistence/{ => schema}/TemplateTableTest.java (97%)
copy confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/{ => plugin}/CreatePipePluginProcedureTest.java (93%)
copy confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/{ => plugin}/DropPipePluginProcedureTest.java (92%)
rename confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/{CreatePipePluginProcedureTest.java => task/CreatePipeProcedureV2Test.java} (57%)
copy confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/{DropPipePluginProcedureTest.java => task/DropPipeProcedureV2Test.java} (80%)
copy confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/{DropPipePluginProcedureTest.java => task/StartPipeProcedureV2Test.java} (80%)
rename confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/{DropPipePluginProcedureTest.java => task/StopPipeProcedureV2Test.java} (80%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeMeta.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeMetaKeeper.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeRuntimeMeta.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeStaticMeta.java
rename node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/{PipeTaskMetaAccessor.java => PipeStatus.java} (61%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeTaskMeta.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeDevicePathCache.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/cache/DataNodeDevicePathCacheTest.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/PredicateRemoveNotRewriter.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/PredicateRemoveNotRewriterTest.java