This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch cp-feaeaa6-dev-1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2950882e3a0 Share WAL measurement schema serialization
add a3f04b5e7b1 Disable IoTV1 region reconstruct IT (#18107)
add 7188fc510ff [Pipe] Improve pipe control-flow lock responsiveness
(#18076) (#18085)
add 187a4d8da77 [dev/1.3] Pipe: preserve TsFile parse OOM cause (#18105)
add 23e40d4b97c Pipe: Remove Ratis data region source restriction (#18089)
(#18100)
add 5b92817bd00 Avoid login lock for pipe auth retry (#18048) (#18101)
add b7285afdc34 Fix stale pipe runtime error messages (#18061) (#18102)
add 170cd74ae4e Pipe: fix manual IT pipe memory config (#18109)
add c8e0935d5d7 Pipe: improve incremental memory estimation (#18049)
(#18113)
add c7c54941e32 Fix StateMachineProcedure EOF state re-execution (#18099)
(#18122)
add f83a5d59858 Fix aligned memtable flush after deleting measurements
(#18116) (#18126)
add a6643abc42d Fix RegionGroupCache activation race (#18128) (#18136)
add 46badda5628 Improve pipe runtime memory allocation (#18051) (#18135)
add 197c137acc1 Pipe: throttle TsFile parser retries under memory pressure
(#18141) (#18152)
add 912bf892f55 Improve pipe receiver session handling (#18084) (#18137)
add f7bdf3294e8 Improve metadata OOM diagnostics (#18039) (#18115)
add e46587e6111 Fix downgraded resource may not serialize normally (#18157)
add 7d0565a6ad3 Fix metadata cache and pipe edge cases (#18147) (#18156)
add 0d81bbce431 Avoid parsing fully matched historical table TsFiles
(#18123) (#18134)
add 12d10a0d416 Pipe: disable serialize-by-region by default (#18140)
add 9ec2add768c [To dev/1.3] Fix the clear logic of specified info of one
operator when print plan in explain analyze (#18168)
add 4df9f9961a9 Add pipe receiver memory protection (#18090) (#18133)
add 3e3414a7c55 Fix subscription consumer lifecycle state ordering
(#18151) (#18169)
add db233b76cf0 Pipe: manage ConfigNode receiver temporary memory (#18144)
(#18170)
add 15db6e58e0d Reduce pipe type conversion log frequency (#18161) (#18173)
add 427d4028bea fix the IoTDBRegionMigrateNormalIT (#18181)
add aa2e761f694 Fix IT log directory test class names (#18131) (#18174)
add 81f59fa39f2 Reduce pipe load success log noise (#18106) (#18183)
add 2c089d39326 Pipe: use session context in legacy receiver loaders
(#18111) (#18184)
add d3fb1eac571 Fix pipe drop stuck on blocking sink reconnect (#18145)
(#18188)
add 9b66d5e528e [Backport 1.3] Avoid read lock when restoring degraded
time index (#18190)
add e2014ff5329 Reduce repeated failure logs (#18175) (#18193)
add f0e8ba2637f [To dev/1.3] Enforce REST query row limit as hard cap
(#18149) (#18197)
add db2dfe965a9 Pipe IT: disable pipe memory control in overridden setups
(#18198) (#18205)
add 54132275259 Pipe: optimize InsertRows schema aggregation (#18195)
(#18207)
add 21c9f9d7f8f [To dev/1.3] Fix retry bug in tree model query which
ignores the time filter (#18201)
add 813de5422cc [Backport][dev/1.3] Improve error message when
auto-creating timeseries with null value (#18210)
add 6636db4a8db [to dev/1.3] Prevent aligned LAST query from hanging with
time filter (#18214)
add 276db4d6b5d Fix MQTT measurement validation (#18217)
add c1050081785 [To dev/1.3] Support debug for query (#18208)
add 8ea23e531e1 Fix write retries, Pipe resource cleanup, subscription
progress, and snapshot recovery (#18180) (#18218)
add 780540cb87a [To dev/1.3] Optimize pipe tablet memory accounting
(#18211) (#18220)
add 8b107926d12 Fix unbounded async pipe sink retries (#18222) (#18225)
add e86ef39d699 Fix repeated RPC dispatch reusing a released
FragmentInstanceContext (NPE) (#17794) (#18235)
add ce72faed052 [Pipe] Include pending historical events in remaining
count (#18216) (#18232)
add 02e190dcfc9 [To dev/1.3] Fix process memory metrics and precision
(#17482) (#18229) (#18231)
add cf5e25025bc Merge dev/1.3 and resolve conflicts
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/it/env/MultiEnvFactory.java | 8 +-
.../it/env/cluster/config/MppCommonConfig.java | 18 ++
.../env/cluster/config/MppSharedCommonConfig.java | 20 ++
.../iotdb/it/env/cluster/env/AbstractEnv.java | 15 +
.../iotdb/it/env/cluster/env/MultiClusterEnv.java | 9 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 19 ++
.../it/env/remote/config/RemoteCommonConfig.java | 12 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../pass/IoTDBRegionMigrateNormalIT.java | 34 +++
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 3 +-
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 17 ++
... => IoTDBAlignedLastQueryWithTimeFilterIT.java} | 44 ++-
.../IoTDBExplainAnalyzePrintIT.java} | 101 ++++---
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 2 +-
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 8 +
.../framework/IoTDBTestRunnerWithParameters.java | 15 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 16 +-
...emoryIT.java => IoTDBPipeTsFileParseOOMIT.java} | 63 ++--
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 10 +-
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 13 +-
.../pipe/it/manual/IoTDBPipePermissionIT.java | 4 +
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 109 ++++++-
iotdb-client/client-go | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../src/test/resources/iotdb-common.properties | 3 +-
iotdb-client/subscription/pom.xml | 5 +
.../consumer/SubscriptionProviders.java | 6 +
.../consumer/SubscriptionPullConsumer.java | 10 +-
.../consumer/SubscriptionPushConsumer.java | 10 +-
.../SubscriptionConsumerLifecycleTest.java | 214 ++++++++++++++
.../handlers/rpc/DataNodeTSStatusRPCHandler.java | 12 +-
.../response/pipe/task/PipeTableResp.java | 6 +
.../load/cache/region/RegionGroupCache.java | 8 +-
.../manager/partition/PartitionManager.java | 8 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 18 +-
.../agent/runtime/PipeConfigRegionListener.java | 19 ++
.../runtime/heartbeat/PipeHeartbeatParser.java | 19 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 90 +++++-
.../resource/PipeConfigNodeResourceManager.java | 19 +-
.../memory/PipeConfigNodeMemoryManager.java | 115 ++++++++
.../persistence/executor/ConfigPlanExecutor.java | 14 +-
.../confignode/persistence/pipe/PipeInfo.java | 5 -
.../confignode/persistence/pipe/PipeTaskInfo.java | 43 ++-
.../confignode/persistence/quota/QuotaInfo.java | 1 +
.../persistence/schema/TemplatePreSetTable.java | 2 +
.../persistence/schema/TemplateTable.java | 12 +-
.../procedure/impl/StateMachineProcedure.java | 15 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 24 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 37 ++-
.../PipeConfigRegionListenerSnapshotTest.java | 59 ++++
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 129 ++++++++-
.../confignode/persistence/QuotaInfoTest.java | 14 +
.../pipe/PipeTaskInfoAutoRestartTest.java | 28 ++
.../schema/TemplatePreSetTableTest.java | 19 +-
.../persistence/schema/TemplateTableTest.java | 10 +-
.../confignode/procedure/STMProcedureTest.java | 70 +++++
.../pipe/AbstractOperatePipeProcedureV2Test.java | 169 +++++++++++
.../assembly/resources/conf/logback-datanode.xml | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +-
.../exception/metadata/PathNotExistException.java | 12 +
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 10 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 296 +++++++++----------
.../task/builder/PipeDataNodeTaskBuilder.java | 92 +++++-
.../agent/task/stage/PipeTaskProcessorStage.java | 5 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 175 ++++++++++--
.../task/subtask/sink/PipeSinkSubtaskManager.java | 101 ++++---
.../common/tsfile/PipeTsFileInsertionEvent.java | 152 +++++++---
.../container/TsFileInsertionDataContainer.java | 12 +-
.../query/TsFileInsertionQueryDataContainer.java | 1 +
.../scan/TsFileInsertionScanDataContainer.java | 14 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 12 +
.../overview/PipeDataNodeSinglePipeMetrics.java | 12 +-
.../processor/aggregate/AggregateProcessor.java | 3 +
.../downsampling/DownSamplingProcessor.java | 3 +
.../receiver/TwoStageAggregateReceiver.java | 11 +
.../exchange/sender/TwoStageAggregateSender.java | 75 ++++-
.../twostage/plugin/TwoStageCountProcessor.java | 9 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 70 ++---
.../protocol/legacy/loader/DeletionLoader.java | 15 +-
.../receiver/protocol/legacy/loader/ILoader.java | 3 +-
.../protocol/legacy/loader/TsFileLoader.java | 12 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 181 ++++++++++--
.../statement/PipeConvertedInsertRowStatement.java | 29 +-
.../PipeConvertedInsertTabletStatement.java | 14 +-
...peStatementDataTypeConvertExecutionVisitor.java | 8 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 17 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 98 ++++++-
.../evolvable/batch/PipeTabletEventBatch.java | 69 ++++-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 12 +-
.../batch/PipeTabletEventTsFileBatch.java | 31 +-
.../request/PipeTransferTabletBatchReq.java | 11 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 49 ++--
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 24 +-
.../pipeconsensus/PipeConsensusSyncSink.java | 20 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 34 ++-
.../PipeConsensusTransferBatchReqBuilder.java | 106 ++++---
.../thrift/async/IoTDBDataRegionAsyncSink.java | 217 +++++++++++---
.../handler/PipeTransferTrackableHandler.java | 29 +-
.../async/handler/PipeTransferTsFileHandler.java | 64 +++--
.../thrift/sync/IoTDBDataRegionSyncSink.java | 160 ++++++++++-
.../source/dataregion/IoTDBDataRegionSource.java | 11 -
.../PipeHistoricalDataRegionTsFileSource.java | 20 +-
.../realtime/PipeRealtimeDataRegionSource.java | 6 +-
.../realtime/epoch/TsFileEpochManager.java | 69 ++++-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 8 +-
.../protocol/rest/handler/QueryRowLimitUtils.java | 68 +++++
.../rest/v1/handler/QueryDataSetHandler.java | 114 ++++----
.../rest/v1/impl/GrafanaApiServiceImpl.java | 19 +-
.../protocol/rest/v1/impl/RestApiServiceImpl.java | 8 +-
.../protocol/rest/v2/handler/FastLastHandler.java | 59 +++-
.../rest/v2/handler/QueryDataSetHandler.java | 114 ++++----
.../rest/v2/impl/GrafanaApiServiceImpl.java | 19 +-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 43 +--
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 72 ++++-
.../impl/DataNodeInternalRPCServiceImpl.java | 54 +---
.../thrift/impl/DataNodeRegionManager.java | 7 +-
.../thrift/impl/PushMultiPipeMetaHelper.java | 85 ++++++
.../db/queryengine/common/MPPQueryContext.java | 317 ++++++++++++++++++++-
.../common/schematree/ClusterSchemaTree.java | 8 +
.../execution/executor/RegionReadExecutor.java | 23 +-
.../fragment/FakedFragmentInstanceContext.java | 2 +-
.../fragment/FragmentInstanceContext.java | 47 ++-
.../fragment/FragmentInstanceExecution.java | 1 -
.../fragment/FragmentInstanceManager.java | 73 +++--
.../execution/fragment/QueryContext.java | 10 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 100 +++++--
.../queryengine/plan/analyze/AnalyzeVisitor.java | 82 ++++--
.../db/queryengine/plan/analyze/Analyzer.java | 16 +-
.../plan/analyze/ConcatPathRewriter.java | 23 +-
.../queryengine/plan/analyze/ExpressionUtils.java | 2 +
.../queryengine/plan/analyze/PredicateUtils.java | 175 +++++++-----
.../plan/analyze/TemplatedAggregationAnalyze.java | 71 ++++-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 20 +-
.../plan/analyze/TreeAnalysisMutationJournal.java | 255 +++++++++++++++++
.../plan/analyze/load/LoadTsFileAnalyzer.java | 38 ++-
.../analyze/schema/AutoCreateSchemaExecutor.java | 1 +
.../analyze/schema/ClusterSchemaFetchExecutor.java | 12 +-
.../plan/execution/IQueryExecution.java | 2 +
.../queryengine/plan/execution/QueryExecution.java | 47 ++-
.../plan/execution/config/ConfigExecution.java | 5 +
.../config/executor/ClusterConfigTaskExecutor.java | 1 +
.../visitor/predicate/PredicateSimplifier.java | 83 ++++--
.../db/queryengine/plan/planner/IPlanner.java | 6 +
.../plan/planner/LogicalPlanBuilder.java | 16 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 20 +-
.../SimpleFragmentParallelPlanner.java | 1 +
.../distribution/WriteFragmentParallelPlanner.java | 3 +-
.../plan/planner/plan/FragmentInstance.java | 29 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 15 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 68 +++--
.../plan/scheduler/load/LoadTsFileScheduler.java | 33 ++-
.../plan/statement/component/GroupByComponent.java | 5 +
.../plan/statement/component/OrderByComponent.java | 30 ++
.../plan/statement/component/WhereCondition.java | 7 +
.../plan/statement/crud/InsertBaseStatement.java | 11 +-
.../plan/statement/crud/InsertRowStatement.java | 10 +-
.../statistics/SpecifiedInfoMergerFactory.java | 13 +
.../statistics/StatisticsMergeUtil.java | 2 -
.../schemaregion/SchemaRegionLoader.java | 8 +-
.../iotdb/db/service/metrics/ProcessMetrics.java | 121 +++++++-
.../db/storageengine/dataregion/DataRegion.java | 42 ++-
.../dataregion/HashLastFlushTimeMap.java | 1 +
.../memtable/AlignedWritableMemChunk.java | 95 ++++--
.../dataregion/memtable/TsFileProcessor.java | 17 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 4 +-
.../dataregion/tsfile/TsFileResource.java | 25 +-
.../load/active/ActiveLoadTsFileLoader.java | 3 +-
.../converter/LoadTsFileDataTypeConverter.java | 1 +
.../storageengine/rescon/disk/FolderManager.java | 11 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 26 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 2 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 6 +-
.../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 71 +++++
.../task/PipeProcessorSubtaskExecutorTest.java | 99 +++++++
.../task/builder/PipeDataNodeTaskBuilderTest.java | 111 ++++++++
.../subtask/sink/PipeSinkSubtaskManagerTest.java | 95 ++++++
.../task/subtask/sink/PipeSinkSubtaskTest.java | 288 +++++++++++++++++++
.../event/TsFileInsertionDataContainerTest.java | 157 ++++++++++
...DataNodeRemainingEventAndTimeOperatorTest.java} | 32 ++-
.../InsertNodeMemoryEstimatorPerformanceTest.java | 104 +++++++
.../memory/InsertNodeMemoryEstimatorTest.java | 79 +++++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 16 ++
.../iotdb/db/pipe/sink/PipeReceiverTest.java | 70 ++++-
.../PipeTransferTabletBatchReqPerformanceTest.java | 126 ++++++++
.../handler/PipeTransferTrackableHandlerTest.java | 74 +++++
.../PipeTransferTsFileHandlerCleanupTest.java | 86 ++++++
.../db/pipe/source/PipeRealtimeExtractTest.java | 76 +++++
.../PipeHistoricalDataRegionTsFileSourceTest.java | 46 +++
.../epoch/TsFileEpochManagerPerformanceTest.java | 210 ++++++++++++++
.../realtime/epoch/TsFileEpochManagerTest.java | 109 +++++++
...ManagerTest.java => MPPPublishHandlerTest.java} | 28 +-
.../rest/handler/QueryRowLimitUtilsTest.java | 59 ++++
.../rest/v1/handler/QueryDataSetHandlerTest.java | 205 +++++++++++++
.../rest/v2/handler/FastLastHandlerTest.java | 108 +++++++
...nternalRPCServiceImplPushMultiPipeMetaTest.java | 246 ++++++++++++++++
.../db/queryengine/common/MPPQueryContextTest.java | 125 ++++++++
.../execution/executor/RegionReadExecutorTest.java | 46 +++
.../execution/operator/MergeSortOperatorTest.java | 5 +
.../plan/analyze/PredicateUtilsTest.java | 172 +++++++++++
.../plan/analyze/TemplatedAnalyzeRetryTest.java | 127 +++++++++
.../plan/execution/QueryExecutionRetryTest.java | 218 ++++++++++++++
.../plan/planner/FragmentInstanceSerdeTest.java | 6 +-
.../plan/planner/LogicalPlanBuilderTest.java | 113 ++++++++
.../load/LoadTsFileDispatcherImplTest.java | 2 +-
.../dataregion/LastFlushTimeMapTest.java | 33 +++
.../memtable/MemChunkDeserializeTest.java | 4 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 28 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 2 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 12 +-
.../dataregion/tsfile/TsFileResourceTest.java | 18 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 21 +-
...ubscriptionPipeTsFileEventBatchCleanupTest.java | 76 +++++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 +-
.../src/test/resources/iotdb-common.properties | 3 +-
.../src/test/resources/iotdb-system.properties | 3 +-
.../conf/iotdb-system.properties.template | 7 +-
.../Triple.java => audit/UserEntity.java} | 40 +--
.../apache/iotdb/commons/conf/CommonConfig.java | 70 ++++-
.../LoggerPeriodicalLogReducer.java} | 63 ++--
.../agent/plugin/builtin/BuiltinPipePlugin.java | 10 +
.../throwing/ThrowingExceptionProcessor.java | 28 ++
.../commons/pipe/agent/task/PipeTaskAgent.java | 49 +++-
.../pipe/agent/task/meta/PipeRuntimeMeta.java | 18 ++
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 4 +
.../task/subtask/PipeAbstractSinkSubtask.java | 127 ++++++---
.../agent/task/subtask/PipeReportableSubtask.java | 51 +++-
.../pipe/agent/task/subtask/PipeSubtask.java | 2 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 14 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 30 +-
.../pipe/config/constant/PipeSinkConstant.java | 5 +-
.../pipe/config/constant/PipeSourceConstant.java | 4 +
.../env/PipeTaskProcessorRuntimeEnvironment.java | 23 ++
.../queue/ConcurrentIterableLinkedQueue.java | 5 +-
.../AbstractSerializableListeningQueue.java | 2 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 149 ++++++++--
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 4 +-
.../commons/pipe/resource/log/PipeLogger.java | 12 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 6 +-
.../common/PipeTransferHandshakeConstant.java | 2 +
.../thrift/common/PipeTransferSliceReqHandler.java | 37 +++
.../thrift/request/PipeTransferCompressedReq.java | 21 ++
.../LoggerPeriodicalLogReducerTest.java} | 21 +-
.../ConcurrentIterableLinkedQueueTest.java | 21 ++
.../listening/AbstractPipeListeningQueueTest.java | 91 ++++++
.../pipe/receiver/IoTDBFileReceiverTest.java | 184 +++++++++++-
.../common/PipeTransferSliceReqBuilderTest.java | 53 ++++
.../request/PipeTransferCompressedReqTest.java | 149 ++++++++++
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 26 ++
.../commons/pipe/task/PipeSleepIntervalTest.java | 86 +++++-
.../openapi/src/main/openapi3/iotdb_rest_v1.yaml | 1 +
.../openapi/src/main/openapi3/iotdb_rest_v2.yaml | 1 +
252 files changed, 10107 insertions(+), 1683 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
=> IoTDBAlignedLastQueryWithTimeFilterIT.java} (56%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBFileTimeIndexIT.java
=> query/IoTDBExplainAnalyzePrintIT.java} (50%)
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/{IoTDBPipeMemoryIT.java
=> IoTDBPipeTsFileParseOOMIT.java} (58%)
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/SubscriptionConsumerLifecycleTest.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/memory/PipeConfigNodeMemoryManager.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/agent/runtime/PipeConfigRegionListenerSnapshotTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2Test.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/handler/QueryRowLimitUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/PushMultiPipeMetaHelper.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TreeAnalysisMutationJournal.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/PipeDataNodeTaskAgentTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/builder/PipeDataNodeTaskBuilderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskManagerTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/{queryengine/execution/fragment/FragmentInfoTest.java
=> pipe/metric/overview/PipeDataNodeRemainingEventAndTimeOperatorTest.java}
(52%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/resource/memory/InsertNodeMemoryEstimatorPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/request/PipeTransferTabletBatchReqPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/handler/PipeTransferTsFileHandlerCleanupTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/epoch/TsFileEpochManagerPerformanceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/epoch/TsFileEpochManagerTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/mqtt/{PayloadFormatManagerTest.java
=> MPPPublishHandlerTest.java} (58%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/handler/QueryRowLimitUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/v1/handler/QueryDataSetHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/v2/handler/FastLastHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplPushMultiPipeMetaTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/common/MPPQueryContextTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/PredicateUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedAnalyzeRetryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecutionRetryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LogicalPlanBuilderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTsFileEventBatchCleanupTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{pipe/datastructure/Triple.java
=> audit/UserEntity.java} (57%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{pipe/resource/log/PipePeriodicalLogReducer.java
=> log/LoggerPeriodicalLogReducer.java} (56%)
rename
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/{pipe/resource/log/PipePeriodicalLogReducerTest.java
=> log/LoggerPeriodicalLogReducerTest.java} (67%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/queue/listening/AbstractPipeListeningQueueTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferCompressedReqTest.java
