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 83e1ca14e1c Fix ITs
add cef9184c294 Pipe: avoid blocking startup on hardlink dir cleanup
(#17932) (#17943)
add 458b5479f96 Fix aggregate write-back output database metadata (#17938)
(#17965)
add ddb9c7cf0a9 [To dev/1.3] Fix pipe schema snapshot database creation
(#17944)
add efdd472b7d1 Fix pipe runtime meta push blocking user operations
(#17909) (#17953)
add 9442a1cbb7e Fix tree model load type mismatch conversion (#17949)
(#17957)
add ef53e32ac82 Fix active load cleanup lifecycle (#17947) (#17963)
add 352da912e21 Throttle async pipe sink on receiver reject (#17928)
(#17966)
add 44ed8578073 [To dev/1.3] Pipe: improve progress coverage checks
(#17967)
add fc581dcbd6a Fix pipe lifecycle restart order in IT (#17962) (#17968)
add 4e06a94d06b Pipe: serialize sink transfers by region (#17946) (#17970)
add 91ee3016d18 Fix duplicate scheduling in procedure execution (#17902)
(#17969)
add d1df10405e0 Stop running AINode (AIClusterIT) integration tests
(#17982)
add aaa5729075a Fix PBTree flush for negative child address (#17955)
(#17978)
add bfb538a15c9 Fix tree schema snapshot database creation on master
(#17964) (#17979)
add 96d55ed221b Improve IT cluster readiness diagnostics (#17903) (#17989)
add eb41f567f54 [to dev/1.3] Fix compaction writer size checkpointing
add f0dc49ec0be Fix pipe text date conversion (#17984) (#17997)
add 9e383898899 Fix SingleDeviceViewOperatorTest row assertion (#17995)
(#18003)
add 073625ad9c1 Fix short reads in fixed-length deserialization (#17870)
(#18007)
add 818b6fc5581 [To dev/1.3] Optimize aggregation metric recording
add 2717029cbb7 Pipe: isolate async sink client resources by endpoint
(#18015) (#18028)
add a7c7e54cb7f [To dev/1.3] Load: Optimize fallback logic for corrupted
TsFile (#18004)
add 896fb6ebdca Fix flaky multilevel priority queue test (#18013) (#18027)
add 617c0a82e12 Support unified pipe pattern inclusion keys (#18017)
add 7fdccc916a4 Limit concurrent load tsfile type conversions (#18014)
(#18030)
add 476f67f8a83 Fix empty deleteTimeseries requests (#18012) (#18037)
add ceaae51b35a Pipe: Fix tablet event alignment and row count handling
(#18034)
add 94bf8a2754f Fix internal procedure deduplication (#18036) (#18043)
add 65d2582cb05 Pipe: merge batched aligned chunks in scan parser (#18010)
(#18041)
add 9ad7c19788c Pipe: Retry history LoadTsFile while waiting for schema
(#18031) (#18042)
add a35a115e409 Fix encrypted password pull consumer commit mode (#18044)
(#18064)
add 59243c5cd29 Pipe: Implemented schema batch for meta transfer (#17665)
(#18067)
add d00d476970e Stabilize ZSTD compressor level pipe IT (#17917) (#18066)
add c0f674cfb1b Throttle empty subscription poll logs (#18063) (#18070)
add a653aeeff1e Avoid copying measurements when updating last cache
(#18059) (#18071)
add 9b124e4f131 Fix tag index memory accounting (#18029) (#18040)
add eb42ffbed2d [to dev/1.3] Add copy fallback for compaction hard links
(#18083)
add 1794e0c128e [To dev/1.3] Support target database in write-back sink
(#18086)
add 8e213ddfffe Pipe: add ConfigNode memory control for log reducer
(#18069) (#18087)
add ab35c4c3c58 Merge remote-tracking branch 'origin/dev/1.3' into
cp-feaeaa6-dev-1.3
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d1a.yml | 64 ---
.github/workflows/pipe-it-2cluster.yml | 6 +
integration-test/pom.xml | 8 +-
.../org/apache/iotdb/it/env/MultiEnvFactory.java | 1 +
.../it/env/cluster/config/MppDataNodeConfig.java | 25 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 221 +++++++-
.../it/env/remote/config/RemoteDataNodeConfig.java | 17 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 8 +
.../iotdb/db/it/IoTDBLoadTsFileActiveRetryIT.java | 226 ++++++++
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 2 +-
.../it/autocreate/IoTDBPipeSinkCompressionIT.java | 180 +++----
.../it/autocreate/IoTDBPipeSinkParallelIT.java | 1 +
.../pipe/it/autocreate/IoTDBPipeSourceIT.java | 60 ++-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 1 +
...RegionIT.java => IoTDBPipeWriteBackSinkIT.java} | 64 +--
.../IoTDBEncryptedPasswordPullConsumerIT.java | 1 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 +-
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 25 +
.../apache/iotdb/session/SessionConnection.java | 3 +
.../org/apache/iotdb/session/pool/SessionPool.java | 3 +
.../iotdb/session/SessionConnectionTest.java | 8 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 11 +
iotdb-client/subscription/pom.xml | 5 +
.../consumer/EmptyPollLogThrottler.java | 62 +++
.../consumer/SubscriptionPullConsumer.java | 22 +-
.../consumer/SubscriptionPushConsumer.java | 21 +-
.../consumer/EmptyPollLogThrottlerTest.java | 63 +++
.../async/AsyncAINodeHeartbeatClientPool.java | 27 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 27 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 33 +-
.../rpc/CheckTimeSeriesExistenceRPCHandler.java | 2 +-
.../rpc/CountPathsUsingTemplateRPCHandler.java | 2 +-
.../rpc/FetchSchemaBlackListRPCHandler.java | 2 +-
.../async/handlers/rpc/SchemaUpdateRPCHandler.java | 2 +-
.../CheckSchemaRegionUsingTemplateRPCHandler.java | 2 +-
.../confignode/conf/ConfigNodeDescriptor.java | 9 +
.../confignode/conf/ConfigNodeMemoryConfig.java | 82 +++
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 10 +
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 13 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 13 +-
.../resource/PipeConfigNodeResourceManager.java | 16 +
.../confignode/persistence/ProcedureInfo.java | 13 +-
.../iotdb/confignode/procedure/Procedure.java | 20 +
.../confignode/procedure/ProcedureExecutor.java | 114 ++--
.../procedure/TimeoutExecutorThread.java | 46 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 236 +++++++--
.../procedure/impl/StateMachineProcedure.java | 3 +-
.../procedure/impl/cq/CreateCQProcedure.java | 2 +-
.../procedure/impl/node/AbstractNodeProcedure.java | 12 +
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 45 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 4 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 4 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 6 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 2 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 2 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 2 +-
.../impl/schema/DeleteDatabaseProcedure.java | 2 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 2 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 2 +-
.../AbstractOperateSubscriptionProcedure.java | 20 +
.../runtime/ConsumerGroupMetaSyncProcedure.java | 10 +-
.../topic/runtime/TopicMetaSyncProcedure.java | 9 +-
.../impl/trigger/CreateTriggerProcedure.java | 2 +-
.../impl/trigger/DropTriggerProcedure.java | 2 +-
.../confignode/procedure/scheduler/LockQueue.java | 10 +-
.../scheduler/SimpleProcedureScheduler.java | 37 +-
.../writelog/io/SingleFileLogReader.java | 5 +-
.../conf/ConfigNodeMemoryConfigTest.java | 19 +-
.../task/PipeTaskCoordinatorLockTest.java | 60 +++
.../pipe/sink/PipeConfigNodeThriftRequestTest.java | 18 +
...eConfigPhysicalPlanPatternParseVisitorTest.java | 42 ++
.../iotdb/confignode/procedure/TestLockRegime.java | 23 +
.../procedure/TestProcedureExecutor.java | 102 ++++
.../procedure/entity/SimpleLockProcedure.java | 11 +-
.../PipeHandleLeaderChangeProcedureTest.java | 47 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 13 +-
...java => LoadAnalyzeMissingSchemaException.java} | 6 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 24 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 150 +++++-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 13 +
.../task/subtask/sink/PipeSinkSubtaskManager.java | 37 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 28 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 8 +-
.../common/tablet/PipeRawTabletEventConverter.java | 50 ++
.../common/tablet/PipeRawTabletInsertionEvent.java | 132 ++++-
.../event/common/tablet/PipeTabletCollector.java | 34 ++
.../tablet/TabletInsertionDataContainer.java | 15 +-
.../query/TsFileInsertionQueryDataContainer.java | 102 +++-
.../container/scan/SinglePageWholeChunkReader.java | 33 +-
.../scan/TsFileInsertionScanDataContainer.java | 587 ++++++++++++++-------
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 58 ++
.../processor/aggregate/AggregateProcessor.java | 13 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 3 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 63 ++-
.../transform/converter/ValueConverter.java | 30 +-
.../visitor/PipeStatementTSStatusVisitor.java | 4 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 257 ++++++++-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 18 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 52 +-
.../batch/PipeSchemaRegionWritePlanEventBatch.java | 555 +++++++++++++++++++
.../evolvable/request/PipeTransferPlanNodeReq.java | 38 +-
.../airgap/IoTDBSchemaRegionAirGapSink.java | 169 +++++-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 116 ++++
.../handler/PipeTransferTrackableHandler.java | 54 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 177 ++++++-
.../sink/protocol/writeback/WriteBackSink.java | 196 ++++++-
.../PipeHistoricalDataRegionTsFileSource.java | 88 +--
.../PipeTsFileEpochProgressIndexKeeper.java | 80 ++-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 3 +
.../impl/DataNodeInternalRPCServiceImpl.java | 20 +-
.../execution/aggregation/Aggregator.java | 92 ++--
.../fragment/FragmentInstanceContext.java | 52 ++
.../execution/operator/OperatorContext.java | 24 +
.../operator/process/AggregationOperator.java | 25 +-
.../process/RawDataAggregationOperator.java | 129 ++---
.../operator/process/TagAggregationOperator.java | 15 +-
.../AbstractSeriesAggregationScanOperator.java | 26 +-
.../metric/QueryExecutionMetricSet.java | 15 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 15 +-
.../analyze/cache/schema/DeviceCacheEntry.java | 20 +-
.../plan/analyze/cache/schema/DeviceLastCache.java | 36 +-
.../analyze/cache/schema/DeviceNormalSchema.java | 13 +-
.../analyze/cache/schema/DeviceSchemaCache.java | 2 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 97 +++-
.../plan/planner/plan/node/write/InsertNode.java | 12 +-
.../planner/plan/node/write/InsertRowNode.java | 12 +-
.../planner/plan/node/write/InsertTabletNode.java | 12 +-
.../datastructure/SerializableList.java | 3 +-
.../logfile/FakeCRC32Deserializer.java | 5 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 69 ++-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 3 +-
.../pbtree/schemafile/log/SchemaFileLogReader.java | 7 +-
.../pbtree/schemafile/pagemgr/PageIOChannel.java | 3 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 9 +-
.../schemaengine/schemaregion/tag/TagLogFile.java | 12 +-
.../schemaengine/schemaregion/tag/TagManager.java | 125 +++--
.../iotdb/db/service/DataNodeShutdownHook.java | 9 +-
.../iotdb/db/storageengine/StorageEngine.java | 3 +
.../RepairUnsortedFileCompactionPerformer.java | 9 +-
.../execute/task/InnerSpaceCompactionTask.java | 13 +-
.../task/InsertionCrossSpaceCompactionTask.java | 13 +-
.../task/RepairUnsortedFileCompactionTask.java | 7 +-
.../utils/writer/AbstractCompactionWriter.java | 164 +++++-
.../writer/AbstractCrossCompactionWriter.java | 3 +-
.../writer/AbstractInnerCompactionWriter.java | 4 +-
.../utils/writer/FastInnerCompactionWriter.java | 10 +-
.../writer/ReadPointCrossCompactionWriter.java | 5 +-
.../writer/ReadPointInnerCompactionWriter.java | 5 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 4 +-
.../dataregion/modification/ModificationFile.java | 3 +-
.../dataregion/wal/io/WALFileVersion.java | 4 +-
.../dataregion/wal/io/WALInputStream.java | 32 +-
.../dataregion/wal/io/WALMetaData.java | 12 +-
.../dataregion/wal/recover/WALRepairWriter.java | 3 +-
.../db/storageengine/load/LoadTsFileManager.java | 13 +
.../storageengine/load/active/ActiveLoadAgent.java | 6 +
.../load/active/ActiveLoadDirScanner.java | 18 +-
.../active/ActiveLoadFailedMessageHandler.java | 16 +
.../active/ActiveLoadScheduledExecutorService.java | 21 +-
.../load/active/ActiveLoadTsFileLoader.java | 27 +-
...ertedInsertTabletStatementExceptionVisitor.java | 9 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 16 +-
.../converter/LoadTreeTsFileTabletIterator.java | 560 ++++++++++++++++++++
.../converter/LoadTsFileDataTypeConverter.java | 95 ++++
.../load/splitter/AlignedChunkData.java | 5 +-
.../response/SubscriptionEventTsFileResponse.java | 11 +-
.../iotdb/db/utils/sort/FileSpillerReader.java | 4 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 39 ++
.../metadata/mtree/schemafile/SchemaFileTest.java | 33 ++
.../agent/plugin/PipeDataNodePluginAgentTest.java | 16 +
.../pipe/event/PipeTabletInsertionEventTest.java | 105 ++++
.../event/TsFileInsertionDataContainerTest.java | 312 +++++++++++
.../schema/PipeSchemaRegionSinkMetricsTest.java | 154 ++++++
.../db/pipe/pattern/PipePatternPruningTest.java | 56 +-
.../receiver/PipeStatementTsStatusVisitorTest.java | 32 ++
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 12 +
.../transform/converter/ValueConverterTest.java | 70 +++
.../sink/IoTDBDataNodeAsyncClientManagerTest.java | 102 ++++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 45 ++
.../db/pipe/sink/PipeSchemaRegionSinkTest.java | 376 +++++++++++++
.../PipeSchemaRegionWritePlanEventBatchTest.java | 463 ++++++++++++++++
.../handler/PipeTransferTrackableHandlerTest.java | 38 +-
.../PipeHistoricalDataRegionTsFileSourceTest.java | 123 +++++
.../PipeTsFileEpochProgressIndexKeeperTest.java | 160 ++++++
.../fragment/FragmentInstanceContextTest.java | 200 +++++++
.../operator/SingleDeviceViewOperatorTest.java | 9 +-
.../queue/MultilevelPriorityQueueTest.java | 13 +-
.../logfile/FakeCRC32DeserializerTest.java | 108 ++++
.../schemaregion/tag/TagLogFileTest.java | 57 ++
.../schemaregion/tag/TagManagerTest.java | 216 ++++++++
.../utils/writer/AbstractCompactionWriterTest.java | 156 ++++++
.../active/ActiveLoadFailedMessageHandlerTest.java | 51 ++
.../load/active/ActiveLoadTsFileLoaderTest.java | 146 +++++
...dInsertTabletStatementExceptionVisitorTest.java | 54 ++
...atementDataTypeConvertExecutionVisitorTest.java | 396 ++++++++++++++
.../src/test/resources/iotdb-system.properties | 1 +
.../conf/iotdb-system.properties.template | 17 +
.../client/request/AsyncRequestManager.java | 45 +-
.../commons/consensus/index/ProgressIndex.java | 11 +
.../index/impl/TimeWindowStateProgressIndex.java | 9 +-
.../commons/executable/ExecutableManager.java | 3 +-
.../iotdb/commons/partition/DataPartition.java | 16 +-
.../plugin/constructor/PipeSinkConstructor.java | 8 +-
.../pipe/config/constant/PipeSinkConstant.java | 22 +
.../pipe/config/constant/PipeSourceConstant.java | 4 +
.../pipe/datastructure/pattern/PipePattern.java | 82 ++-
.../queue/serializer/PlainQueueSerializer.java | 3 +-
.../resource/log/PipePeriodicalLogReducer.java | 71 +--
.../pipe/sink/protocol/IoTDBAirGapSink.java | 5 +-
.../commons/pipe/sink/protocol/IoTDBSink.java | 8 +
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 17 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 24 +-
.../client/request/AsyncRequestManagerTest.java | 221 ++++++++
.../pattern/PipePatternParseTest.java | 83 +++
.../resource/log/PipePeriodicalLogReducerTest.java | 65 +++
.../apache/iotdb/commons/utils/IOUtilsTest.java | 147 ++++++
220 files changed, 10583 insertions(+), 1306 deletions(-)
delete mode 100644 .github/workflows/cluster-it-1c1d1a.yml
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileActiveRetryIT.java
copy
integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/{IoTDBPipeMultiSchemaRegionIT.java
=> IoTDBPipeWriteBackSinkIT.java} (54%)
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/EmptyPollLogThrottler.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/EmptyPollLogThrottlerTest.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeMemoryConfig.java
copy
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TSStatusCodeTest.java
=>
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/conf/ConfigNodeMemoryConfigTest.java
(57%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinatorLockTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/{DirectoryNotLegalException.java
=> LoadAnalyzeMissingSchemaException.java} (85%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeSchemaRegionWritePlanEventBatch.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeTsFileTabletIterator.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/schema/PipeSchemaRegionSinkMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/transform/converter/ValueConverterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/IoTDBDataNodeAsyncClientManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeSchemaRegionSinkTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/PipeSchemaRegionWritePlanEventBatchTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileSourceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/PipeTsFileEpochProgressIndexKeeperTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceContextTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/logfile/FakeCRC32DeserializerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagLogFileTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/writer/AbstractCompactionWriterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadFailedMessageHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/LoadConvertedInsertTabletStatementExceptionVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/LoadTreeStatementDataTypeConvertExecutionVisitorTest.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/resource/log/PipePeriodicalLogReducer.java
(52%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/request/AsyncRequestManagerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/pattern/PipePatternParseTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/resource/log/PipePeriodicalLogReducerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/IOUtilsTest.java
