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 2ac954004d50f233d8b33cf1915a32212d7a51ee Merge: 4d4284c19eb 5cb388190ae Author: HTHou <[email protected]> AuthorDate: Tue Jun 24 15:14:43 2025 +0800 Merge branch 'master' of github.com:apache/iotdb into ssl_between_nodes .../it/env/cluster/config/MppDataNodeConfig.java | 12 + .../it/env/cluster/node/AbstractNodeWrapper.java | 4 + .../it/env/remote/config/RemoteDataNodeConfig.java | 10 + .../apache/iotdb/itbase/env/DataNodeConfig.java | 4 + .../IoTDBRemoveConfigNodeITFramework.java | 2 +- .../IoTDBRemoveDataNodeNormalIT.java | 362 ++++++++++++++++++++- .../removedatanode/IoTDBRemoveDataNodeUtils.java | 178 ++++++++++ ...work.java => IoTDBRemoveUnknownDataNodeIT.java} | 324 ++++++++---------- .../confignode/it/utils/ConfigNodeTestUtils.java | 12 + .../iotdb/db/it/IoTDBCustomizedClusterIT.java | 148 +++++++++ .../relational/it/db/it/IoTDBWindowFunctionIT.java | 170 +++++++++- .../relational/it/db/it/IoTDBWindowTVFIT.java | 175 ++++++++++ .../it/query/recent/IoTDBTableAggregationIT.java | 181 ++++++++--- .../query/view/recent/IoTDBTableViewQueryIT.java | 5 + .../recent/IoTDBTableViewWithTreeTTLQueryIT.java | 38 ++- .../relational/it/schema/IoTDBDatabaseIT.java | 4 +- .../iotdb/relational/it/schema/IoTDBTableIT.java | 72 ++-- .../org/apache/iotdb/subscription/it/Retry.java | 26 +- .../apache/iotdb/subscription/it/RetryRule.java | 69 ++++ ...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 8 + ...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 8 + .../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 7 + .../api/exception/UDFColumnNotFoundException.java | 14 +- .../api/exception/UDFTypeMismatchException.java | 14 +- .../table/argument/ScalarArgumentChecker.java | 8 + .../java/org/apache/iotdb/udf/api/type/Type.java | 10 + .../org/apache/iotdb/tool/common/Constants.java | 3 +- .../subscription/SubscriptionTableTsFile.java | 2 +- .../subscription/SubscriptionTreeTsFile.java | 2 +- iotdb-client/client-cpp/src/main/Common.h | 15 +- .../client-cpp/src/main/IoTDBRpcDataSet.cpp | 68 ++-- iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.h | 42 +-- iotdb-client/client-cpp/src/main/NodesSupplier.cpp | 16 +- .../client-cpp/src/main/SessionDataSet.cpp | 78 +++-- iotdb-client/client-cpp/src/main/SessionDataSet.h | 32 +- iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 66 ++-- .../src/test/cpp/sessionRelationalIT.cpp | 81 ++++- .../java/org/apache/iotdb/session/Session.java | 6 +- .../apache/iotdb/session/TableSessionBuilder.java | 7 +- iotdb-core/ainode/ainode/core/config.py | 10 +- iotdb-core/ainode/ainode/core/constant.py | 22 +- .../ainode/core/manager/inference_manager.py | 22 +- .../ainode/ainode/core/manager/model_manager.py | 48 ++- .../ainode/core/model/built_in_model_factory.py | 67 ++-- .../ainode/ainode/core/model/model_storage.py | 103 +++--- .../ainode/core/model/sundial/modeling_sundial.py | 22 +- .../ainode/core/model/timerxl/modeling_timer.py | 22 +- .../iotdb/confignode/manager/ConfigManager.java | 14 +- .../iotdb/confignode/manager/ProcedureManager.java | 44 ++- .../region/GreedyCopySetRegionGroupAllocator.java | 8 +- .../pipe/agent/task/PipeConfigNodeSubtask.java | 9 +- .../subscription/SubscriptionCoordinator.java | 3 +- .../partition/DatabasePartitionTable.java | 10 +- .../persistence/partition/PartitionInfo.java | 2 +- .../persistence/partition/RegionGroup.java | 6 +- .../impl/node/RemoveDataNodesProcedure.java | 5 +- .../region/NotifyRegionMigrationProcedure.java | 2 +- .../procedure/impl/schema/SchemaUtils.java | 20 +- .../table/AbstractAlterOrDropTableProcedure.java | 23 +- .../impl/schema/table/CreateTableProcedure.java | 8 +- .../impl/schema/table/RenameTableProcedure.java | 6 +- .../GreedyCopySetRemoveNodeReplicaSelectTest.java | 11 +- .../consensus/iot/logdispatcher/LogDispatcher.java | 2 +- .../consensus/iot/logdispatcher/SyncStatus.java | 5 +- .../consensus/pipe/PipeConsensusServerImpl.java | 19 +- .../assembly/resources/conf/logback-datanode.xml | 6 +- .../apache/iotdb/db/auth/BasicAuthorityCache.java | 2 +- .../iotdb/db/auth/ClusterAuthorityFetcher.java | 5 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 - .../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 29 +- .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 24 ++ .../airgap/IoTDBDataRegionAirGapConnector.java | 2 +- .../pipeconsensus/PipeConsensusAsyncConnector.java | 28 +- .../handler/PipeConsensusDeleteEventHandler.java | 4 +- .../PipeConsensusTabletInsertionEventHandler.java | 5 +- .../PipeConsensusTsFileInsertionEventHandler.java | 10 +- .../async/IoTDBDataRegionAsyncConnector.java | 2 +- .../thrift/sync/IoTDBDataRegionSyncConnector.java | 6 +- .../util/builder/PipeTableModelTsFileBuilder.java | 1 + .../builder/PipeTableModelTsFileBuilderV2.java | 53 +-- .../util/builder/PipeTreeModelTsFileBuilder.java | 1 + .../util/builder/PipeTreeModelTsFileBuilderV2.java | 42 ++- .../event/realtime/PipeRealtimeEventFactory.java | 6 +- .../dataregion/IoTDBDataRegionExtractor.java | 25 +- ...oricalDataRegionTsFileAndDeletionExtractor.java | 2 +- .../PipeDataNodeRemainingEventAndTimeOperator.java | 30 +- .../overview/PipeWALInsertNodeCacheMetrics.java | 4 +- .../pipeconsensus/PipeConsensusReceiver.java | 12 +- .../pipeconsensus/PipeConsensusReceiverAgent.java | 138 ++++---- .../protocol/thrift/IoTDBDataNodeReceiver.java | 63 ++-- .../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 4 +- .../iotdb/db/protocol/session/SessionManager.java | 14 + .../protocol/thrift/impl/ClientRPCServiceImpl.java | 73 +++-- .../impl/DataNodeInternalRPCServiceImpl.java | 10 +- .../execution/driver/DriverContext.java | 6 + .../exchange/source/LocalSourceHandle.java | 13 +- .../fragment/FakedFragmentInstanceContext.java | 106 ++++++ .../fragment/FragmentInstanceContext.java | 19 +- .../fragment/FragmentInstanceManager.java | 8 +- .../execution/fragment/QueryContext.java | 2 +- .../process/PatternRecognitionOperator.java | 6 + .../rowpattern/expression/ArithmeticOperator.java | 7 +- .../rowpattern/expression/ComparisonOperator.java | 8 +- .../process/rowpattern/expression/Computation.java | 9 +- .../rowpattern/expression/LogicalOperator.java | 4 +- .../expression/PatternExpressionComputation.java | 3 +- .../process/window/TableWindowOperator.java | 1 - .../window/partition/PartitionExecutor.java | 6 +- .../process/window/partition/frame/RangeFrame.java | 6 +- .../process/window/utils/RowComparator.java | 20 ++ .../schema/source/TableDeviceQuerySource.java | 23 +- .../execution/operator/source/SeriesScanUtil.java | 6 +- .../execution/schedule/task/DriverTaskId.java | 3 +- .../iotdb/db/queryengine/plan/Coordinator.java | 13 + .../db/queryengine/plan/analyze/TypeProvider.java | 8 +- .../schema/dualkeycache/impl/DualKeyCacheImpl.java | 1 + .../plan/analyze/load/LoadTsFileAnalyzer.java | 9 +- .../metadata/relational/ShowCreateViewTask.java | 9 +- .../plan/planner/OperatorTreeGenerator.java | 12 +- .../plan/planner/TableOperatorGenerator.java | 65 +++- .../queryengine/plan/planner/TreeModelPlanner.java | 2 +- .../SimpleFragmentParallelPlanner.java | 1 + .../plan/planner/distribution/SourceRewriter.java | 70 +++- .../memory/FakedMemoryReservationManager.java | 23 +- .../plan/planner/plan/PlanFragment.java | 9 + .../planner/plan/node/process/AggregationNode.java | 3 +- .../plan/node/process/RawDataAggregationNode.java | 3 +- .../source/AlignedSeriesAggregationScanNode.java | 21 +- .../node/source/SeriesAggregationScanNode.java | 15 +- .../planner/plan/parameter/SeriesScanOptions.java | 24 +- .../relational/analyzer/ExpressionAnalyzer.java | 24 +- .../function/tvf/ForecastTableFunction.java | 16 +- .../metadata/fetcher/TableDeviceSchemaFetcher.java | 12 +- .../fetcher/TableDeviceSchemaValidator.java | 6 +- .../plan/relational/planner/QueryPlanner.java | 42 ++- .../relational/planner/TableLogicalPlanner.java | 5 + .../plan/relational/planner/TableModelPlanner.java | 2 +- .../distribute/TableDistributedPlanGenerator.java | 11 + .../distribute/TableModelQueryFragmentPlanner.java | 1 + .../optimizations/PushPredicateIntoTableScan.java | 3 +- .../planner/optimizations/SortElimination.java | 60 +++- .../planner/rowpattern/IrRowPattern.java | 40 +-- .../plan/relational/sql/parser/AstBuilder.java | 17 +- .../plan/scheduler/ClusterScheduler.java | 11 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 101 +++++- .../plan/scheduler/IFragInstanceDispatcher.java | 6 +- .../scheduler/load/LoadTsFileDispatcherImpl.java | 4 +- .../plan/scheduler/load/LoadTsFileScheduler.java | 29 +- .../db/schemaengine/table/DataNodeTableCache.java | 42 ++- .../iotdb/db/schemaengine/table/ITableCache.java | 10 +- .../iotdb/db/service/DataNodeShutdownHook.java | 33 +- .../db/storageengine/dataregion/DataRegion.java | 3 +- .../dataregion/tsfile/TsFileResourceList.java | 2 +- .../dataregion/utils/TsFileResourceUtils.java | 5 +- .../storageengine/dataregion/wal/WALManager.java | 11 +- .../file/AbstractTsFileRecoverPerformer.java | 2 +- .../receiver/SubscriptionReceiverV1.java | 6 + .../SchemaRegionSimpleRecoverTest.java | 4 +- ...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 43 ++- .../distribution/AggregationAlignByDeviceTest.java | 57 ++++ .../analyzer/RowPatternRecognitionTest.java | 32 ++ .../plan/relational/analyzer/TreeViewTest.java | 4 +- .../fetcher/cache/TableDeviceSchemaCacheTest.java | 12 +- .../security/encrypt/MessageDigestEncryptTest.java | 12 +- .../storageengine/dataregion/DataRegionTest.java | 4 +- .../TableModelCompactionWithTTLTest.java | 4 +- .../file/UnsealedTsFileRecoverPerformerTest.java | 4 +- .../org/apache/iotdb/metrics/utils/MetricInfo.java | 3 +- .../conf/iotdb-system.properties.template | 2 +- .../commons/auth/authorizer/BasicAuthorizer.java | 42 ++- .../commons/concurrent/IoTDBThreadPoolFactory.java | 28 ++ .../iotdb/commons/concurrent/ThreadName.java | 1 + .../apache/iotdb/commons/conf/CommonConfig.java | 52 +-- .../commons/exception/QueryTimeoutException.java | 4 + .../org/apache/iotdb/commons/path/PartialPath.java | 12 + .../pipe/agent/task/meta/PipeRuntimeMeta.java | 9 + .../commons/pipe/agent/task/meta/PipeTaskMeta.java | 25 +- .../iotdb/commons/pipe/config/PipeConfig.java | 20 +- .../iotdb/commons/pipe/config/PipeDescriptor.java | 19 +- .../thrift/request/PipeTransferCompressedReq.java | 15 + .../iotdb/commons/pipe/event/EnrichedEvent.java | 4 +- .../security/encrypt/AsymmetricEncrypt.java | 23 +- .../security/encrypt/MessageDigestEncrypt.java | 10 +- .../relational/tvf/VariationTableFunction.java | 196 +++++++++-- .../udf/builtin/relational/tvf/WindowTVFUtils.java | 6 +- .../org/apache/iotdb/commons/utils/AuthUtils.java | 22 +- .../thrift-datanode/src/main/thrift/client.thrift | 1 + .../src/main/thrift/datanode.thrift | 1 + pom.xml | 4 +- 189 files changed, 3875 insertions(+), 1248 deletions(-)
