This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch ssl_between_nodes in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 64761e2a963665f6a10fa87224609b6a11f6f870 Merge: 23dc90a4543 f69347580e8 Author: HTHou <[email protected]> AuthorDate: Tue Jul 15 18:26:23 2025 +0800 Merge branch 'master' of github.com:apache/iotdb into ssl_between_nodes .github/workflows/multi-language-client.yml | 10 +- RELEASE_NOTES.md | 22 + dependencies.json | 14 +- .../org/apache/iotdb/it/env/cluster/EnvUtils.java | 77 +++- .../it/env/cluster/config/MppCommonConfig.java | 23 + .../env/cluster/config/MppSharedCommonConfig.java | 26 ++ .../iotdb/it/env/cluster/env/AbstractEnv.java | 266 ++++++++--- .../it/env/cluster/node/AbstractNodeWrapper.java | 9 +- .../it/env/remote/config/RemoteCommonConfig.java | 16 + .../org/apache/iotdb/itbase/env/CommonConfig.java | 8 + .../org/apache/iotdb/ainode/it/AINodeBasicIT.java | 270 ----------- .../iotdb/ainode/it/AINodeClusterConfigIT.java | 113 +++++ .../iotdb/ainode/it/AINodeInferenceSQLIT.java | 292 ++++++++++++ .../iotdb/ainode/it/AINodeModelManageIT.java | 215 +++++++++ .../apache/iotdb/ainode/utils/AINodeTestUtils.java | 126 ++++++ .../it/IoTDBConfigNodeSnapshot2IT.java} | 36 +- .../confignode/it/IoTDBConfigNodeSnapshotIT.java | 5 +- .../IoTDBRemoveDataNodeNormalIT.java | 4 +- .../IoTDBRemoveUnknownDataNodeIT.java | 4 +- .../iotdb/db/it/IoTDBCustomizedClusterIT.java | 127 +++++- .../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 4 +- .../maxby/IoTDBMaxByAlignedSeriesIT.java | 20 + .../db/it/aggregation/maxby/IoTDBMaxByIT.java | 21 +- .../db/it/aggregation/minby/IoTDBMinByIT.java | 5 +- .../db/it/last/IoTDBLastQueryLastCacheIT.java | 15 +- .../IoTDBArithmeticDivAndModWithoutDoubleIT.java | 70 +++ .../withoutNull/IoTDBWithoutNullAllFilterIT.java | 48 +- .../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 48 +- .../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 8 +- .../it/db/it/IoTDBPatternAggregationIT.java | 492 +++++++++++++++++++++ .../relational/it/db/it/IoTDBWindowFunctionIT.java | 63 +++ .../view/recent/IoTDBNullValueTableViewIT.java | 14 +- .../query/view/recent/IoTDBTableViewQueryIT.java | 24 + .../IoTDBTableViewQueryWithCachedDeviceIT.java | 127 ++++++ .../relational/it/schema/IoTDBDatabaseIT.java | 32 +- .../iotdb/session/it/IoTDBSessionSimpleIT.java | 16 + .../org/apache/iotdb/session/it/SessionIT.java | 133 +++++- .../it/cluster/IoTDBSubscriptionRestartIT.java | 4 + .../it/dual/AbstractSubscriptionDualIT.java | 4 + .../it/local/AbstractSubscriptionLocalIT.java | 2 + .../it/triple/AbstractSubscriptionTripleIT.java | 12 + .../AbstractSubscriptionTreeRegressionIT.java | 71 ++- .../IoTDBRootPullConsumeTsfileIT.java | 15 +- .../format/IoTDBDBTsfilePullConsumerIT.java | 18 +- .../IoTDBAllTsTsfilePullConsumerIT.java | 16 +- .../IoTDBAllTsfilePullConsumerSnapshotIT.java | 14 +- .../IoTDBPathDeviceTsfilePullConsumerIT.java | 17 +- .../IoTDBTimeTsTsfilePullConsumerIT.java | 17 +- .../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 16 +- .../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 33 +- .../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 39 +- .../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 15 +- .../IoTDBDevicePatternPullConsumeTsfileIT.java | 14 +- .../IoTDBRootPatternPullConsumeTsfileIT.java | 12 +- .../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 15 +- .../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 8 + .../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 11 + .../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 4 +- .../apache/iotdb/tools/it/ExportTsFileTestIT.java | 3 + .../src/test/resources/ainode-example/config.yaml | 8 +- .../apache/iotdb/tool/data/ExportDataTable.java | 5 +- .../java/org/apache/iotdb/isession/ISession.java | 6 +- .../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 + .../java/org/apache/iotdb/session/Session.java | 261 ++++++----- .../apache/iotdb/session/SessionConnection.java | 6 +- .../subscription/AbstractSubscriptionSession.java | 2 +- .../subscription/SubscriptionSessionWrapper.java | 4 +- .../base/AbstractSubscriptionProvider.java | 31 +- .../apache/iotdb/session/util/SessionUtils.java | 103 +++-- .../iotdb/session/util/SessionUtilsTest.java | 26 +- iotdb-core/ainode/ainode/core/ainode.py | 167 +++++++ iotdb-core/ainode/ainode/core/config.py | 77 +++- iotdb-core/ainode/ainode/core/constant.py | 55 +-- iotdb-core/ainode/ainode/core/exception.py | 5 + iotdb-core/ainode/ainode/core/ingress/dataset.py | 20 +- iotdb-core/ainode/ainode/core/ingress/iotdb.py | 278 +++++++----- .../ainode/core/manager/inference_manager.py | 37 +- .../ainode/ainode/core/manager/model_manager.py | 36 +- .../ainode/core/model/built_in_model_factory.py | 131 +++--- iotdb-core/ainode/ainode/core/model/model_info.py | 160 +++++++ .../ainode/ainode/core/model/model_storage.py | 358 +++++++++++++-- .../core/model/sundial/ts_generation_mixin.py | 5 + .../core/{ingress/dataset.py => rpc/__init__.py} | 15 - iotdb-core/ainode/ainode/core/{ => rpc}/client.py | 2 +- iotdb-core/ainode/ainode/core/{ => rpc}/handler.py | 14 +- iotdb-core/ainode/ainode/core/rpc/service.py | 101 +++++ .../ainode/ainode/core/{util => rpc}/status.py | 0 iotdb-core/ainode/ainode/core/script.py | 112 +---- iotdb-core/ainode/ainode/core/service.py | 57 --- .../ainode/resources/conf/iotdb-ainode.properties | 32 +- .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 11 +- .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 + iotdb-core/confignode/pom.xml | 2 +- .../rpc/DataNodeAsyncRequestRPCHandler.java | 2 +- .../handlers/rpc/PipeHeartbeatRPCHandler.java | 2 +- .../request/write/ainode/RemoveAINodePlan.java | 5 + .../consensus/response/model/ModelTableResp.java | 13 +- .../iotdb/confignode/manager/ConfigManager.java | 59 +-- .../apache/iotdb/confignode/manager/IManager.java | 7 +- .../iotdb/confignode/manager/ModelManager.java | 60 ++- .../iotdb/confignode/manager/node/NodeManager.java | 20 +- .../pipe/agent/task/PipeConfigNodeTaskAgent.java | 22 +- .../protocol/IoTDBConfigRegionAirGapConnector.java | 5 + .../protocol/IoTDBConfigRegionConnector.java | 13 +- .../runtime/heartbeat/PipeHeartbeatParser.java | 2 - .../runtime/heartbeat/PipeHeartbeatScheduler.java | 2 +- .../receiver/protocol/IoTDBConfigNodeReceiver.java | 7 +- .../iotdb/confignode/persistence/ModelInfo.java | 28 +- .../iotdb/confignode/persistence/TriggerInfo.java | 3 - .../iotdb/confignode/persistence/UDFInfo.java | 3 - .../confignode/persistence/pipe/PipeTaskInfo.java | 7 +- .../procedure/impl/model/DropModelProcedure.java | 57 +-- .../procedure/impl/node/RemoveAINodeProcedure.java | 24 + .../impl/pipe/runtime/PipeMetaSyncProcedure.java | 4 +- .../impl/pipe/task/AlterPipeProcedureV2.java | 16 +- .../impl/pipe/task/CreatePipeProcedureV2.java | 18 +- .../procedure/state/RemoveAINodeState.java | 1 + .../iotdb/confignode/service/ConfigNode.java | 12 +- .../confignode/service/ConfigNodeShutdownHook.java | 3 - .../thrift/ConfigNodeRPCServiceProcessor.java | 15 +- .../request/ConfigPhysicalPlanSerDeTest.java | 12 +- .../consensus/response/pipe/PipeTableRespTest.java | 6 +- .../agent/PipeConfigNodeSubtaskExecutorTest.java | 3 +- .../iotdb/confignode/persistence/PipeInfoTest.java | 4 +- iotdb-core/consensus/pom.xml | 14 +- .../apache/iotdb/consensus/pipe/PipeConsensus.java | 3 +- .../pipe/consensuspipe/ConsensusPipeConnector.java | 4 +- .../consensuspipe/ReplicateProgressManager.java | 2 +- .../pipe/metric/PipeConsensusSyncLagManager.java | 12 +- iotdb-core/datanode/pom.xml | 2 +- .../iotdb/db/exception/load/LoadFileException.java | 4 + .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 90 ++-- .../task/builder/PipeDataNodeTaskBuilder.java | 68 ++- .../task/execution/PipeSubtaskExecutorManager.java | 6 +- .../subtask/connector/PipeConnectorSubtask.java | 5 + .../connector/PipeConnectorSubtaskManager.java | 4 + .../subtask/processor/PipeProcessorSubtask.java | 4 +- .../client/IoTDBDataNodeAsyncClientManager.java | 20 +- .../airgap/IoTDBDataRegionAirGapConnector.java | 31 ++ .../airgap/IoTDBSchemaRegionAirGapConnector.java | 5 + .../pipeconsensus/PipeConsensusAsyncConnector.java | 13 +- .../async/IoTDBDataRegionAsyncConnector.java | 20 +- .../handler/PipeTransferTrackableHandler.java | 2 + .../async/handler/PipeTransferTsFileHandler.java | 28 +- .../thrift/sync/IoTDBDataRegionSyncConnector.java | 21 + .../thrift/sync/IoTDBSchemaRegionConnector.java | 5 + .../connector/util/builder/PipeTsFileBuilder.java | 40 +- .../ReplicateProgressDataNodeManager.java | 21 +- .../event/common/heartbeat/PipeHeartbeatEvent.java | 6 +- .../statement/PipeStatementInsertionEvent.java | 6 +- .../tablet/PipeInsertNodeTabletInsertionEvent.java | 6 +- .../common/tablet/PipeRawTabletInsertionEvent.java | 6 +- .../common/tsfile/PipeTsFileInsertionEvent.java | 6 +- .../event/realtime/PipeRealtimeEventFactory.java | 50 +-- .../dataregion/IoTDBDataRegionExtractor.java | 14 +- ...oricalDataRegionTsFileAndDeletionExtractor.java | 37 +- .../PipeRealtimeDataRegionHybridExtractor.java | 5 +- .../realtime/assigner/PipeDataRegionAssigner.java | 18 +- .../listener/PipeInsertionDataNodeListener.java | 11 +- .../schemaregion/IoTDBSchemaRegionExtractor.java | 4 +- .../iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 6 +- .../PipeDataNodeRemainingEventAndTimeOperator.java | 18 +- ...ics.java => PipeDataNodeSinglePipeMetrics.java} | 15 +- .../pipe/metric/overview/PipeResourceMetrics.java | 14 + .../pipeconsensus/PipeConsensusReceiver.java | 75 ++-- .../protocol/thrift/IoTDBDataNodeReceiver.java | 5 + .../iotdb/db/protocol/client/ConfigNodeClient.java | 11 +- .../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 4 + .../protocol/rest/v2/handler/FastLastHandler.java | 71 +++ .../rest/v2/handler/RequestValidationHandler.java | 8 + .../protocol/rest/v2/impl/RestApiServiceImpl.java | 230 +++++++--- .../protocol/thrift/impl/ClientRPCServiceImpl.java | 8 +- .../impl/DataNodeInternalRPCServiceImpl.java | 28 +- .../db/queryengine/common/MPPQueryContext.java | 29 ++ .../execution/MemoryEstimationHelper.java | 28 ++ .../queryengine/execution/QueryStateMachine.java | 62 +-- .../execution/exchange/SharedTsBlockQueue.java | 2 +- .../queryengine/execution/exchange/sink/ISink.java | 4 +- .../execution/exchange/sink/LocalSinkChannel.java | 14 +- .../execution/exchange/sink/ShuffleSinkHandle.java | 40 +- .../execution/exchange/sink/SinkChannel.java | 10 +- .../execution/fragment/DataNodeQueryContext.java | 21 +- .../fragment/FragmentInstanceContext.java | 7 + .../fragment/FragmentInstanceExecution.java | 44 +- .../process/PatternRecognitionOperator.java | 8 + .../operator/process/ProjectOperator.java | 3 +- .../operator/process/ai/InferenceOperator.java | 3 +- .../join/SimpleNestedLoopCrossJoinOperator.java | 3 +- .../last/AbstractUpdateLastCacheOperator.java | 24 +- .../last/AlignedUpdateLastCacheOperator.java | 14 +- .../AlignedUpdateViewPathLastCacheOperator.java | 10 +- .../operator/process/last/LastQueryOperator.java | 1 + .../process/last/LastQuerySortOperator.java | 10 +- .../process/last/LastQueryTransformOperator.java | 4 +- .../operator/process/last/LastQueryUtil.java | 34 ++ .../process/last/UpdateLastCacheOperator.java | 27 +- .../last/UpdateViewPathLastCacheOperator.java | 4 +- .../rowpattern/PatternAggregationTracker.java | 156 +++++++ .../process/rowpattern/PatternAggregator.java | 178 ++++++++ .../process/rowpattern/PatternAggregators.java | 74 ++++ .../rowpattern/PatternPartitionExecutor.java | 13 + .../rowpattern/PatternVariableRecognizer.java | 8 +- .../rowpattern/PhysicalAggregationPointer.java} | 15 +- .../process/rowpattern/expression/Computation.java | 15 +- .../expression/PatternExpressionComputation.java | 18 +- .../process/rowpattern/matcher/Matcher.java | 29 +- .../process/window/TableWindowOperator.java | 6 +- .../window/partition/PartitionExecutor.java | 11 +- .../AbstractSeriesAggregationScanOperator.java | 70 ++- .../source/AbstractSeriesScanOperator.java | 46 +- .../execution/operator/source/SeriesScanUtil.java | 73 ++- .../relational/AbstractAggTableScanOperator.java | 75 +++- .../AbstractDefaultAggTableScanOperator.java | 4 +- .../relational/AbstractMergeSortJoinOperator.java | 14 + .../relational/AbstractTableScanOperator.java | 16 +- .../relational/DeviceIteratorScanOperator.java | 3 +- .../InformationSchemaContentSupplierFactory.java | 125 ++++-- .../relational/LastQueryAggTableScanOperator.java | 4 +- .../iotdb/db/queryengine/plan/Coordinator.java | 6 + .../db/queryengine/plan/analyze/Analysis.java | 33 +- .../queryengine/plan/analyze/AnalyzeVisitor.java | 99 +++-- .../plan/analyze/ExpressionTypeAnalyzer.java | 29 ++ .../queryengine/plan/analyze/ExpressionUtils.java | 14 +- .../queryengine/plan/execution/QueryExecution.java | 8 +- .../execution/config/TableConfigTaskVisitor.java | 57 ++- .../execution/config/TreeConfigTaskVisitor.java | 24 +- .../config/executor/ClusterConfigTaskExecutor.java | 99 ++++- .../config/executor/IConfigTaskExecutor.java | 16 +- .../CreateModelTask.java => RemoveAINodeTask.java} | 22 +- .../config/metadata/ai/CreateModelTask.java | 14 +- .../config/metadata/ai/CreateTrainingTask.java | 41 +- .../config/metadata/ai/ShowModelsTask.java | 72 ++- .../execution/config/sys/pipe/ShowPipeTask.java | 4 +- .../memory/StatementMemorySourceVisitor.java | 3 +- .../visitor/ColumnTransformerVisitor.java | 11 + .../db/queryengine/plan/parser/ASTVisitor.java | 36 +- .../plan/planner/LogicalPlanBuilder.java | 152 +++---- .../plan/planner/OperatorTreeGenerator.java | 160 ++++--- .../plan/planner/SubPlanTypeExtractor.java | 6 - .../plan/planner/TableOperatorGenerator.java | 173 +++++++- .../planner/distribution/ExchangeNodeAdder.java | 15 +- .../planner/distribution/NodeGroupContext.java | 12 + .../SimpleFragmentParallelPlanner.java | 12 +- .../plan/planner/distribution/SourceRewriter.java | 152 +++++-- .../plan/planner/plan/node/PlanGraphPrinter.java | 18 +- .../plan/planner/plan/node/PlanNodeType.java | 14 +- .../plan/planner/plan/node/PlanVisitor.java | 5 - .../plan/node/process/MultiChildProcessNode.java | 4 + .../plan/node/process/last/LastQueryNode.java | 141 +++++- .../plan/node/source/AlignedLastQueryScanNode.java | 245 ---------- .../plan/node/source/LastQueryScanNode.java | 193 ++++++-- .../relational/analyzer/ExpressionAnalyzer.java | 155 ++++++- .../relational/analyzer/StatementAnalyzer.java | 18 +- .../function/tvf/ForecastTableFunction.java | 22 +- .../metadata/fetcher/TableDeviceSchemaFetcher.java | 53 ++- .../plan/relational/planner/QueryPlanner.java | 2 +- .../plan/relational/planner/RelationPlanner.java | 57 ++- .../distribute/TableDistributedPlanGenerator.java | 24 +- .../planner/optimizations/SymbolMapper.java | 49 +- .../optimizations/TransformSortToStreamSort.java | 33 +- .../planner/rowpattern/AggregationLabelSet.java | 100 +++++ .../rowpattern/AggregationValuePointer.java | 161 +++++++ .../rowpattern/ExpressionAndValuePointers.java | 16 + .../plan/relational/sql/ast/AstVisitor.java | 12 + .../plan/relational/sql/ast/CreateModel.java | 72 +++ .../plan/relational/sql/ast/CreateTraining.java | 85 +--- .../plan/relational/sql/ast/DropModel.java | 64 +++ .../plan/relational/sql/ast/Identifier.java | 6 +- .../plan/relational/sql/ast/RemoveAINode.java | 64 +++ .../plan/relational/sql/parser/AstBuilder.java | 101 ++--- .../scheduler/FixedRateFragInsStateTracker.java | 34 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 7 +- .../plan/statement/StatementVisitor.java | 5 + .../plan/statement/crud/QueryStatement.java | 10 +- ...elStatement.java => RemoveAINodeStatement.java} | 43 +- .../metadata/model/CreateModelStatement.java | 10 +- .../metadata/model/CreateTrainingStatement.java | 14 +- .../metadata/model/DropModelStatement.java | 10 +- .../metadata/model/ShowModelsStatement.java | 12 +- .../metadata/view/CreateLogicalViewStatement.java | 13 +- .../dag/input/QueryDataSetInputLayer.java | 3 + .../apache/iotdb/db/schemaengine/SchemaEngine.java | 10 +- .../java/org/apache/iotdb/db/service/DataNode.java | 13 +- .../iotdb/db/service/DataNodeShutdownHook.java | 39 +- .../org/apache/iotdb/db/service/MQTTService.java | 2 +- .../metrics/IoTDBInternalLocalReporter.java | 2 +- .../iotdb/db/service/metrics/WritingMetrics.java | 13 + .../utils/reader/SeriesDataBlockReader.java | 20 +- .../dataregion/memtable/TsFileProcessor.java | 8 + .../dataregion/snapshot/SnapshotLoader.java | 67 ++- .../tsfile/generator/TsFileNameGenerator.java | 63 +-- .../allocation/AbstractNodeAllocationStrategy.java | 13 +- .../db/storageengine/load/LoadTsFileManager.java | 12 +- .../storageengine/load/disk/ILoadDiskSelector.java | 3 +- .../InheritSystemMultiDisksStrategySelector.java | 42 +- .../db/storageengine/load/disk/MinIOSelector.java | 3 +- .../load/limiter/LoadTsFileRateLimiter.java | 64 +-- .../storageengine/rescon/disk/FolderManager.java | 63 +++ .../db/storageengine/rescon/disk/TierManager.java | 4 + .../rescon/disk/strategy/DirectoryStrategy.java | 34 ++ .../strategy/MaxDiskUsableSpaceFirstStrategy.java | 3 + .../MinFolderOccupiedSpaceFirstStrategy.java | 4 + .../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 + .../rescon/disk/strategy/SequenceStrategy.java | 4 +- .../agent/SubscriptionReceiverAgent.java | 16 +- .../agent/SubscriptionRuntimeAgent.java | 4 + .../db/subscription/broker/SubscriptionBroker.java | 35 +- .../broker/SubscriptionPrefetchingQueue.java | 387 +++++++++++++++- .../broker/SubscriptionPrefetchingTabletQueue.java | 7 +- .../broker/SubscriptionPrefetchingTsFileQueue.java | 6 - .../SubscriptionPipeEventBatchSegmentLock.java | 75 ++++ .../event/batch/SubscriptionPipeEventBatches.java | 118 ++--- .../batch/SubscriptionPipeTsFileEventBatch.java | 40 +- .../receiver/SubscriptionReceiverV1.java | 2 + .../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +- .../iotdb/db/utils/sort/FileSpillerReader.java | 4 +- .../queryengine/execution/exchange/StubSink.java | 6 +- .../execution/operator/LastQueryOperatorTest.java | 6 +- .../operator/LastQueryTreeSortOperatorTest.java | 6 +- ...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 69 ++- .../process/TableStreamSortOperatorTest.java | 11 +- .../operator/process/rowpattern/MatcherTest.java | 4 +- .../db/queryengine/plan/analyze/AnalyzeTest.java | 4 +- .../plan/planner/distribution/LastQueryTest.java | 22 +- .../logical/DataQueryLogicalPlannerTest.java | 86 ++-- .../node/source/LastQueryScanNodeSerdeTest.java | 70 +++ .../plan/relational/analyzer/AnalyzerTest.java | 5 +- .../plan/relational/analyzer/JoinTest.java | 188 ++++++++ .../plan/relational/analyzer/SubQueryTest.java | 24 + .../relational/analyzer/TableFunctionTest.java | 82 ++++ .../planner/assertions/PlanMatchPattern.java | 4 + .../AlignedSeriesScanLimitOffsetPushDownTest.java | 97 ++-- .../AlignedSeriesScanPredicatePushDownTest.java | 47 +- ...gleColumnSeriesScanLimitOffsetPushDownTest.java | 48 +- .../read/reader/series/SeriesReaderTestUtil.java | 17 + .../series/SeriesScanLimitOffsetPushDownTest.java | 60 +-- .../series/SeriesScanPredicatePushDownTest.java | 40 +- iotdb-core/node-commons/pom.xml | 2 +- .../apache/iotdb/commons/client/ClientManager.java | 27 +- .../iotdb/commons/client/IClientManager.java | 3 + .../iotdb/commons/client/ainode/AINodeClient.java | 30 ++ .../async/AsyncPipeDataTransferServiceClient.java | 2 +- .../iotdb/commons/concurrent/ThreadName.java | 5 +- .../apache/iotdb/commons/conf/CommonConfig.java | 109 ++--- .../iotdb/commons/conf/CommonDescriptor.java | 5 + .../commons/exception/PortOccupiedException.java} | 14 +- .../iotdb/commons/model/ModelInformation.java | 2 +- .../iotdb/commons/partition/DataPartition.java | 11 +- .../org/apache/iotdb/commons/path/PartialPath.java | 4 + .../agent/runtime/PipePeriodicalJobExecutor.java | 33 -- .../commons/pipe/agent/task/PipeTaskAgent.java | 13 +- .../commons/pipe/agent/task/meta/PipeMeta.java | 6 +- .../pipe/agent/task/meta/PipeRuntimeMeta.java | 51 +-- .../commons/pipe/agent/task/meta/PipeTaskMeta.java | 142 +----- .../task/progress/PipeEventCommitManager.java | 11 - .../iotdb/commons/pipe/config/PipeConfig.java | 34 +- .../iotdb/commons/pipe/config/PipeDescriptor.java | 31 +- .../config/constant/PipeConnectorConstant.java | 5 + .../connector/limiter/GlobalRPCRateLimiter.java} | 17 +- .../pipe/connector/limiter/GlobalRateLimiter.java | 14 +- .../connector/limiter/TsFileSendRateLimiter.java | 34 +- .../connector/protocol/IoTDBAirGapConnector.java | 3 + .../pipe/connector/protocol/IoTDBConnector.java | 4 +- .../connector/protocol/IoTDBSslSyncConnector.java | 17 +- .../commons/pipe/receiver/IoTDBFileReceiver.java | 66 +-- .../commons/pipe/resource/log/PipeLogManager.java | 2 +- .../commons/pipe/resource/log/PipeLogStatus.java | 4 +- .../schema/column/ColumnHeaderConstant.java | 5 +- .../iotdb/commons/service/metric/enums/Metric.java | 1 + .../subscription/config/SubscriptionConfig.java | 6 + .../apache/iotdb/commons/utils/JVMCommonUtils.java | 56 ++- .../apache/iotdb/commons/utils/StatusUtils.java | 15 +- .../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 22 +- .../db/relational/grammar/sql/RelationalSql.g4 | 36 +- iotdb-doap.rdf | 8 + .../openapi/src/main/openapi3/iotdb_rest_v2.yaml | 25 ++ .../thrift-ainode/src/main/thrift/ainode.thrift | 18 +- .../thrift-commons/src/main/thrift/common.thrift | 7 + .../src/main/thrift/confignode.thrift | 23 +- .../src/main/thrift/datanode.thrift | 9 +- pom.xml | 22 +- 381 files changed, 10162 insertions(+), 4199 deletions(-)
