You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2025/11/28 03:22:15 UTC
(iotdb) 04/06: Merge branch 'master' of github.com:apache/iotdb into opt_aligned_tvlist
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 <ha...@apache.org>
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(-)