This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch opt_aligned_tvlist in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 51edae5795b6b46c55c3084732f7a7e71c2d7e3a Merge: ead01cd0a4c b1ab9b3eb97 Author: HTHou <[email protected]> AuthorDate: Wed Aug 27 17:20:40 2025 +0800 Merge branch 'master' of github.com:apache/iotdb into opt_aligned_tvlist .../it/env/cluster/config/MppCommonConfig.java | 6 - .../env/cluster/config/MppSharedCommonConfig.java | 7 - .../it/env/remote/config/RemoteCommonConfig.java | 5 - .../org/apache/iotdb/itbase/env/CommonConfig.java | 2 - .../relational/it/query/recent/IoTDBCteIT.java | 332 +++++++++++++++++++++ .../response/pipe/task/PipeTableResp.java | 11 +- .../agent/runtime/PipeConfigNodeRuntimeAgent.java | 11 +- .../pipe/agent/task/PipeConfigNodeSubtask.java | 51 ++-- .../pipe/agent/task/PipeConfigNodeTaskAgent.java | 11 +- .../pipe/agent/task/PipeConfigNodeTaskBuilder.java | 6 +- .../PipeConfigPhysicalPlanTSStatusVisitor.java | 1 + .../pipe/source/IoTDBConfigRegionSource.java | 2 +- .../confignode/persistence/pipe/PipeInfo.java | 10 +- .../confignode/persistence/pipe/PipeTaskInfo.java | 16 +- .../impl/pipe/AbstractOperatePipeProcedureV2.java | 4 +- .../impl/pipe/runtime/PipeMetaSyncProcedure.java | 4 +- .../impl/pipe/task/CreatePipeProcedureV2.java | 4 +- .../pipe/util/PipeExternalSourceLoadBalancer.java | 2 +- .../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 61 +++- .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 19 +- .../agent/task/builder/PipeDataNodeBuilder.java | 2 +- .../task/builder/PipeDataNodeTaskBuilder.java | 6 +- .../pipe/agent/task/stage/PipeTaskSourceStage.java | 9 +- .../agent/task/subtask/sink/PipeSinkSubtask.java | 66 ++-- .../task/subtask/sink/PipeSinkSubtaskManager.java | 6 +- ...istoricalDataRegionTsFileAndDeletionSource.java | 6 +- .../PipeRealtimeDataRegionHybridSource.java | 1 + .../realtime/PipeRealtimeDataRegionLogSource.java | 1 + .../realtime/PipeRealtimeDataRegionSource.java | 21 +- .../PipeRealtimeDataRegionTsFileSource.java | 2 + .../dataregion/realtime/epoch/TsFileEpoch.java | 28 +- .../realtime/epoch/TsFileEpochManager.java | 3 - .../db/pipe/source/mqtt/MQTTPublishHandler.java | 4 +- .../iotdb/db/pipe/source/mqtt/MQTTSource.java | 6 +- .../config/executor/ClusterConfigTaskExecutor.java | 14 +- .../relational/analyzer/StatementAnalyzer.java | 15 +- .../plan/relational/planner/RelationPlanner.java | 23 ++ .../iotdb/db/service/DataNodeShutdownHook.java | 4 + .../subtask/SubscriptionSinkSubtaskManager.java | 2 +- .../agent/plugin/PipeDataNodePluginAgentTest.java | 4 +- .../db/pipe/consensus/DeletionResourceTest.java | 4 +- .../pattern/CachedSchemaPatternMatcherTest.java | 9 +- .../db/pipe/source/PipeRealtimeExtractTest.java | 10 +- .../apache/iotdb/commons/conf/CommonConfig.java | 12 + .../iotdb/commons/conf/CommonDescriptor.java | 2 + .../commons/pipe/agent/plugin/PipePluginAgent.java | 8 +- .../commons/pipe/agent/task/PipeTaskAgent.java | 14 +- .../pipe/agent/task/meta/PipeStaticMeta.java | 58 ++-- .../task/subtask/PipeAbstractSinkSubtask.java | 16 +- ....java => PipeTaskSourceRuntimeEnvironment.java} | 9 +- .../iotdb/commons/pipe/source/IoTDBSource.java | 6 +- 51 files changed, 672 insertions(+), 264 deletions(-)
