This is an automated email from the ASF dual-hosted git repository. weihao pushed a commit to branch optimizeLast in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c557454a8603982511bb774bf681d899160c95fe Merge: bbc91a12b78 35ef0c8ba42 Author: Weihao Li <[email protected]> AuthorDate: Wed Mar 4 14:36:25 2026 +0800 Merge branch 'master' into optimizeLast README.md | 2 +- README_ZH.md | 2 +- dependencies.json | 18 +- .../java/org/apache/iotdb/SessionPoolExample.java | 2 +- .../treemodel/auto/basic/IoTDBPipeAlterIT.java | 45 ++++ .../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 4 +- .../treemodel/manual/IoTDBPipePermissionIT.java | 128 ++++++++++- .../view/recent/IoTDBComplexQueryTableViewIT.java | 18 +- .../iotdb/relational/it/schema/IoTDBTableIT.java | 54 ++--- .../api/customizer/parameter/PipeParameters.java | 4 +- .../api/exception/PipePasswordCheckException.java | 26 +-- .../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 + .../iotdb/confignode/conf/ConfigNodeConfig.java | 11 + .../confignode/conf/ConfigNodeDescriptor.java | 3 + .../iotdb/confignode/manager/ConfigManager.java | 5 +- .../apache/iotdb/confignode/manager/IManager.java | 3 +- .../confignode/manager/PermissionManager.java | 5 +- .../iotdb/confignode/manager/ProcedureManager.java | 32 +++ .../runtime/PipeLeaderChangeHandler.java | 5 +- .../pipe/coordinator/task/PipeTaskCoordinator.java | 14 +- .../coordinator/task/PipeTaskCoordinatorLock.java | 19 +- .../receiver/protocol/IoTDBConfigNodeReceiver.java | 2 +- .../pipe/source/ConfigRegionListeningFilter.java | 84 ++++--- .../pipe/source/IoTDBConfigRegionSource.java | 20 +- .../manager/schema/ClusterSchemaManager.java | 14 +- .../subscription/SubscriptionCoordinator.java | 10 +- .../confignode/persistence/auth/AuthorInfo.java | 5 +- .../persistence/auth/AuthorPlanExecutor.java | 5 +- .../persistence/auth/IAuthorPlanExecutor.java | 3 +- .../schema/CNPhysicalPlanGenerator.java | 10 +- .../procedure/env/RegionMaintainHandler.java | 245 +++++++++++++++++++-- .../impl/pipe/task/AlterPipeProcedureV2.java | 19 +- .../impl/pipe/task/CreatePipeProcedureV2.java | 13 +- .../impl/region/AddRegionPeerProcedure.java | 5 + .../impl/region/CreateRegionGroupsProcedure.java | 6 + .../impl/region/RemoveRegionPeerProcedure.java | 45 +++- .../procedure/state/AddRegionPeerState.java | 1 + .../procedure/state/CreateRegionGroupsState.java | 5 +- .../procedure/state/RemoveRegionPeerState.java | 1 + .../thrift/ConfigNodeRPCServiceProcessor.java | 5 +- .../confignode/persistence/AuthorInfoTest.java | 2 +- .../consensus/config/PipeConsensusConfig.java | 16 -- .../apache/iotdb/consensus/pipe/PipeConsensus.java | 39 ++-- .../consensus/pipe/PipeConsensusServerImpl.java | 223 +++---------------- .../pipe/consensuspipe/ConsensusPipeManager.java | 157 ------------- .../pipe/metric/PipeConsensusSyncLagManager.java | 10 +- .../service/PipeConsensusRPCServiceProcessor.java | 3 +- .../org/apache/iotdb/db/auth/AuthorityChecker.java | 10 +- .../iotdb/db/auth/ClusterAuthorityFetcher.java | 26 ++- .../apache/iotdb/db/auth/IAuthorityFetcher.java | 3 +- .../db/consensus/DataRegionConsensusImpl.java | 2 - .../pipe/agent/plugin/PipeDataNodePluginAgent.java | 40 ++-- .../dataregion/PipeDataRegionPluginAgent.java | 22 +- .../consensus/ConsensusPipeDataNodeDispatcher.java | 131 ----------- .../overview/PipeDataNodeSinglePipeMetrics.java | 16 +- .../schema/PipeSchemaRegionSourceMetrics.java | 38 ++-- .../protocol/thrift/IoTDBDataNodeReceiver.java | 2 +- .../protocol/airgap/IoTDBDataRegionAirGapSink.java | 5 + .../sink/protocol/writeback/WriteBackSink.java | 23 ++ .../source/dataregion/IoTDBDataRegionSource.java | 117 ++++++---- ...istoricalDataRegionTsFileAndDeletionSource.java | 17 +- .../realtime/PipeRealtimeDataRegionSource.java | 10 +- .../schemaregion/IoTDBSchemaRegionSource.java | 32 ++- .../schemaregion/SchemaRegionListeningFilter.java | 7 +- .../db/protocol/session/InternalClientSession.java | 2 +- .../iotdb/db/protocol/session/SessionManager.java | 26 ++- .../common/header/DatasetHeaderFactory.java | 2 +- .../operator/schema/source/DeviceSchemaSource.java | 2 +- .../relational/AbstractTableScanOperator.java | 10 +- .../analyze/cache/partition/PartitionCache.java | 3 + .../execution/config/TreeConfigTaskVisitor.java | 7 +- .../config/executor/ClusterConfigTaskExecutor.java | 121 ++++++---- .../metadata/relational/ShowCreateViewTask.java | 2 +- .../execution/config/sys/pipe/AlterPipeTask.java | 8 +- .../execution/config/sys/pipe/CreatePipeTask.java | 20 +- .../config/sys/pipe/PipeFunctionSupport.java | 2 +- .../plan/planner/OperatorTreeGenerator.java | 2 +- .../plan/planner/distribution/SourceRewriter.java | 8 +- .../node/metadata/read/DevicesSchemaScanNode.java | 24 +- .../metadata/fetcher/TableDeviceSchemaFetcher.java | 12 +- .../sql/ast/AbstractQueryDeviceWithCache.java | 15 +- .../plan/relational/sql/parser/AstBuilder.java | 30 ++- .../read/resp/info/impl/ShowDevicesResult.java | 4 +- .../java/org/apache/iotdb/db/service/DataNode.java | 61 ++--- .../db/storageengine/dataregion/DataRegion.java | 4 + .../performer/impl/FastCompactionPerformer.java | 7 - .../execute/utils/MultiTsFileDeviceIterator.java | 93 ++------ .../fast/FastAlignedSeriesCompactionExecutor.java | 18 +- .../dataregion/memtable/TsFileProcessor.java | 49 +---- .../subtask/SubscriptionSinkSubtaskManager.java | 3 +- .../apache/iotdb/db/utils/DataNodeAuthUtils.java | 6 +- .../auth/authorizer/LocalFileAuthorizerTest.java | 8 +- .../db/auth/authorizer/OpenIdAuthorizerTest.java | 8 +- .../source/relational/TableScanOperatorTest.java | 113 ++++++++++ .../logical/SchemaQueryLogicalPlannerTest.java | 6 +- .../dataregion/memtable/TsFileProcessorTest.java | 158 ------------- .../commons/auth/authorizer/BasicAuthorizer.java | 7 +- .../iotdb/commons/auth/authorizer/IAuthorizer.java | 3 +- .../commons/auth/authorizer/OpenIdAuthorizer.java | 3 +- .../apache/iotdb/commons/conf/CommonConfig.java | 21 ++ .../commons/pipe/agent/plugin/PipePluginAgent.java | 33 +-- .../agent/task/execution/PipeSubtaskExecutor.java | 18 +- .../iotdb/commons/pipe/config/PipeConfig.java | 4 + .../iotdb/commons/pipe/config/PipeDescriptor.java | 7 + .../pipe/receiver/PipeReceiverStatusHandler.java | 10 +- .../pipe/source/IoTDBNonDataRegionSource.java | 3 + .../iotdb/commons/pipe/source/IoTDBSource.java | 19 +- .../schema/column/ColumnHeaderConstant.java | 2 +- .../src/main/thrift/confignode.thrift | 1 + pom.xml | 2 +- scripts/sbin/windows/start-cli.bat | 18 +- 111 files changed, 1517 insertions(+), 1318 deletions(-)
