This is an automated email from the ASF dual-hosted git repository. vgalaxies pushed a commit to branch sub-client in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 244d374ca7506f4bcf82f8e3e469ca4ed6cbaeed Merge: f381c3e313c 9a67740018a Author: VGalaxies <[email protected]> AuthorDate: Thu Mar 12 21:57:46 2026 +0800 Merge branch 'master' into sub-client .dockerignore | 2 + .github/workflows/multi-language-client.yml | 8 +- .mvn/wrapper/maven-wrapper.properties | 2 +- README.md | 2 +- README_ZH.md | 2 +- RELEASE_NOTES.md | 47 +++ dependencies.json | 18 +- docker/ReadMe.md | 20 ++ .../main/DockerCompose/docker-compose-ainode.yml | 3 + docker/src/main/Dockerfile-1.0.0-ainode | 66 ---- docker/src/main/Dockerfile-2.0.x-ainode | 88 +++++ docker/src/main/ainode-entrypoint.sh | 150 ++++++++ docker/src/main/build-ainode.sh | 270 ++++++++++++++ example/client-cpp-example/pom.xml | 4 +- .../org/apache/iotdb/TableModelJDBCExample.java | 7 +- .../java/org/apache/iotdb/SessionPoolExample.java | 2 +- .../org/apache/iotdb/TableModelSessionExample.java | 7 +- .../apache/iotdb/TableModelSessionPoolExample.java | 9 +- .../iotdb/it/env/cluster/ClusterConstant.java | 2 +- .../iotdb/it/env/cluster/env/AbstractEnv.java | 33 +- .../itbase/runtime/ClusterTestConnection.java | 10 +- .../iotdb/itbase/runtime/ClusterTestResultSet.java | 14 +- .../iotdb/itbase/runtime/ClusterTestStatement.java | 11 +- .../itbase/runtime/ParallelRequestDelegate.java | 9 +- .../org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 23 ++ .../IoTDBIoTConsensusV23C3DBasicITBase.java | 298 ++++++++++++++++ .../batch/IoTDBIoTConsensusV2Batch3C3DBasicIT.java | 52 +++ .../IoTDBIoTConsensusV2Stream3C3DBasicIT.java | 52 +++ .../treemodel/auto/basic/IoTDBPipeAlterIT.java | 45 +++ .../view/recent/IoTDBComplexQueryTableViewIT.java | 18 +- .../iotdb/relational/it/schema/IoTDBTableIT.java | 54 +-- iotdb-client/client-cpp/pom.xml | 16 +- .../iotdb/confignode/conf/ConfigNodeConfig.java | 11 + .../confignode/conf/ConfigNodeDescriptor.java | 3 + .../consensus/request/ConfigPhysicalPlanType.java | 1 - .../iotdb/confignode/manager/ProcedureManager.java | 32 ++ .../pipe/coordinator/runtime/PipeMetaSyncer.java | 20 ++ .../pipe/coordinator/task/PipeTaskCoordinator.java | 20 +- .../coordinator/task/PipeTaskCoordinatorLock.java | 19 +- .../subscription/SubscriptionCoordinator.java | 10 +- .../persistence/auth/AuthorPlanExecutor.java | 2 - .../persistence/executor/ConfigPlanExecutor.java | 1 - .../confignode/persistence/pipe/PipeTaskInfo.java | 14 + .../procedure/env/RegionMaintainHandler.java | 334 +++++++++++++++++- .../impl/pipe/task/AlterPipeProcedureV2.java | 8 +- .../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 + .../request/ConfigPhysicalPlanTypeTest.java} | 37 +- .../pipe/PipeTaskInfoConsensusPipeTest.java | 152 ++++++++ .../RegionMaintainHandlerConsensusPipeTest.java | 290 +++++++++++++++ .../consensus/config/PipeConsensusConfig.java | 65 +--- .../apache/iotdb/consensus/pipe/PipeConsensus.java | 68 +--- .../consensus/pipe/PipeConsensusServerImpl.java | 234 +------------ .../pipe/consensuspipe/ConsensusPipeGuardian.java | 26 -- .../pipe/consensuspipe/ConsensusPipeManager.java | 157 --------- .../pipe/consensuspipe/ConsensusPipeSelector.java | 28 -- .../service/PipeConsensusRPCServiceProcessor.java | 3 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 58 +++ .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 46 +++ .../db/consensus/DataRegionConsensusImpl.java | 8 - .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 21 -- .../task/builder/PipeDataNodeTaskBuilder.java | 3 +- .../consensus/ConsensusPipeDataNodeDispatcher.java | 131 ------- .../ConsensusPipeDataNodeRuntimeAgentGuardian.java | 48 --- .../protocol/airgap/IoTDBDataRegionAirGapSink.java | 5 + .../source/dataregion/IoTDBDataRegionSource.java | 31 +- .../common/header/DatasetHeaderFactory.java | 2 +- .../operator/schema/source/DeviceSchemaSource.java | 2 +- .../execution/operator/source/SeriesScanUtil.java | 64 ++-- .../relational/AbstractTableScanOperator.java | 10 +- .../config/executor/ClusterConfigTaskExecutor.java | 11 +- .../metadata/relational/ShowCreateViewTask.java | 2 +- .../plan/planner/OperatorTreeGenerator.java | 2 +- .../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 | 89 +++-- .../db/storageengine/dataregion/DataRegion.java | 60 +++- .../performer/impl/FastCompactionPerformer.java | 7 - .../execute/utils/MultiTsFileDeviceIterator.java | 93 +---- .../fast/FastAlignedSeriesCompactionExecutor.java | 18 +- .../impl/RewriteCrossSpaceCompactionSelector.java | 6 + .../dataregion/memtable/TsFileProcessor.java | 49 +-- .../subtask/SubscriptionSinkSubtaskManager.java | 3 +- .../org/apache/iotdb/db/tools/DelayAnalyzer.java | 387 +++++++++++++++++++++ .../source/relational/TableScanOperatorTest.java | 113 ++++++ .../logical/SchemaQueryLogicalPlannerTest.java | 6 +- .../dataregion/memtable/TsFileProcessorTest.java | 158 --------- .../apache/iotdb/db/tools/DelayAnalyzerTest.java | 361 +++++++++++++++++++ .../conf/iotdb-system.properties.template | 32 ++ .../apache/iotdb/commons/conf/CommonConfig.java | 21 ++ .../iotdb/commons/pipe/config/PipeConfig.java | 4 + .../iotdb/commons/pipe/config/PipeDescriptor.java | 7 + .../schema/column/ColumnHeaderConstant.java | 2 +- iotdb-doap.rdf | 48 +++ pom.xml | 6 +- scripts/sbin/windows/start-cli.bat | 18 +- 103 files changed, 3542 insertions(+), 1417 deletions(-)
