This is an automated email from the ASF dual-hosted git repository.
Wei-hao-Li pushed a change to branch mppEx
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c02cd116b7b fix according review
add 2a654e66745 Fix deleteDirectoryIfExists when root Path is not exist
(#18593)
add 6343e1fe7a0 Restrict COPY TO export paths (#18573)
add 47844ddc737 Optimize aligned memtable encoding for null values (#18610)
add 6c2b747ede6 [Pipe] Fix batch and async resource lifecycle leaks
(#18582)
add c2ead3be72f Fix Java client time column access throwing
ArrayIndexOutOfBoundsException (#17407) (#17408)
add 6a3c8d667f0 [Load] Preserve invalid device path failures during tablet
conversion (#18614)
add b1a046211b1 [AINode] Replace DiT-derived Sundial conditioning head
(#18616)
add 55736e2ee28 Add MOMENT license and copyright notice (#18611)
add ab6f8a214e1 [AINode] Add third-party attributions to binary package
(#18620)
add 320f0d5a839 [Subscription] Suppress expected commit progress warnings
(#18615)
add 510c8cddd2b Fix pipe visibility and mask credentials in show create
(#18617)
add 3ea1fc666ac Delete empty TsFile sidecars after LOAD (#18599)
add 31621ef2602 Fix metric about device entry disk io- #18609
add c05881ba28c bump tsfile version (#18629)
add 0f9f1ebb300 Change schema region sync logs to debug (#18632)
add a467cf3d430 [Pipe] Honor SECURITY privilege for relational auth
synchronization (#18624)
add 63ae0f35e0e Add SHOW RECEIVERS support (#17869)
add 280c0189aa5 Support standard TLS and mTLS in the C++ client (#18601)
add 37e3e6630e2 [Pipe] Stabilize IoTDBPipeAutoSplitIT for auto-dropped
history pipe (#18621)
add a05c63e0abb Fix aligned flush values after time deletion (#18634)
add 7c8e4cbc27d Fix flaky IoTDBAutoRegionGroupExtension2IT during DataNode
shutdown (#18642)
add 0f64600571b Optimize Python session result decoding (#18638)
add e2ac222343b [Pipe] Restore sink progress under memory pressure (#18640)
add 2838c35317f [Pipe] Stabilize receiver and compression integration
tests (#18644)
add 34528ad93d3 Stop publishing standalone CLI and node distributions
(#18622)
add 1151ba762ff Fix TVList iterator state across memtable page switches
(#18647)
add 11470dafb6f Fix WAL roll recovery after closed channel (#18653)
add fefbbbcf0fa [Subscription] Balance consensus ownership and report WAL
backlog (#18641)
add e967831ca2a [Pipe] Drop builtin sinks synchronously (#18646)
add 016d58b47fb [Subscription] Relax group credentials and report
connection failures (#18658)
add 76796db4782 [Subscription] Bound consumer close when server is
unresponsive (#18659)
add 25bf38eba0c [Query] Fix result-column OOM diagnostics (#18661)
add 2b6d628e022 [Pipe] Fix deletion buffer close flush race (#18662)
add 5b9e8868c47 [ConfigNode] Skip non-existent and duplicate region IDs
during reconstruction (#18664)
add 5d67dae28c8 Fix init of DeviceEntryBatchSizeInBytes config when there
is no properties file (#18660)
add c611a389e7d Fix table model JDBC example TTL retrieval (#18669)
add 929774bd1b8 resolve conflict
No new revisions were added by this update.
Summary of changes:
.github/scripts/test-edge-ops.py | 2 -
.github/workflows/client-cpp-package.yml | 38 +-
.github/workflows/multi-language-client.yml | 7 +-
LICENSE | 56 ++
NOTICE | 10 +-
distribution/pom.xml | 6 -
.../{common-files.xml => ainode-common-files.xml} | 6 +-
distribution/src/assembly/ainode.xml | 2 +-
distribution/src/assembly/cli.xml | 74 --
distribution/src/assembly/confignode.xml | 92 --
distribution/src/assembly/datanode.xml | 94 --
docker/ReadMe.md | 17 +-
docker/src/main/DockerCompose/do-docker-build.sh | 6 +-
docker/src/main/Dockerfile-1.0.0-confignode | 2 +-
docker/src/main/Dockerfile-1.0.0-datanode | 5 +-
.../org/apache/iotdb/TableModelJDBCExample.java | 8 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 6 +-
.../IoTDBAutoRegionGroupExtension2IT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 27 +
.../basic/IoTDBPipeRelationalSecurityIT.java | 162 ++++
.../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 19 +-
.../auto/basic/IoTDBShowReceiversLifecycleIT.java | 364 ++++++++
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 6 +
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 12 +-
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 219 +++++
.../pipe/it/single/IoTDBPipePermissionIT.java | 9 +-
.../iotdb/pipe/it/single/IoTDBPipeReceiverIT.java | 631 --------------
.../iotdb/pipe/it/single/IoTDBShowReceiversIT.java | 717 ++++++++++++++++
.../pipe/it/triple/IoTDBShowReceiversTripleIT.java | 287 +++++++
.../relational/it/db/it/IoTDBDeletionTableIT.java | 57 ++
.../query/recent/copyto/IoTDBCopyToTsFileIT.java | 86 ++
.../relational/it/schema/IoTDBDatabaseIT.java | 21 +-
iotdb-client/client-cpp/CMakeLists.txt | 14 +
iotdb-client/client-cpp/README.md | 53 +-
iotdb-client/client-cpp/README_zh.md | 12 +-
iotdb-client/client-cpp/cmake/FetchOpenSSL.cmake | 201 +++--
.../client-cpp/cmake/InstallOpenSSLRuntime.cmake | 4 +-
iotdb-client/client-cpp/pom.xml | 62 +-
.../package-metadata/third_party/DEPENDENCIES.md | 2 +-
.../src/include/AbstractSessionBuilder.h | 15 +-
iotdb-client/client-cpp/src/include/Session.h | 3 +
.../client-cpp/src/include/SessionBuilder.h | 14 +-
iotdb-client/client-cpp/src/include/SessionC.h | 15 +
iotdb-client/client-cpp/src/include/SessionPool.h | 21 +-
.../src/include/{Status.h => SslConfig.h} | 20 +-
iotdb-client/client-cpp/src/include/TableSession.h | 3 +-
.../client-cpp/src/include/TableSessionBuilder.h | 14 +-
iotdb-client/client-cpp/src/rpc/NodesSupplier.cpp | 33 +-
iotdb-client/client-cpp/src/rpc/NodesSupplier.h | 13 +-
.../client-cpp/src/rpc/RpcSslUtils.cpp | 29 +-
.../src/rpc/RpcSslUtils.h} | 20 +-
.../client-cpp/src/rpc/SessionConnection.cpp | 13 +-
.../client-cpp/src/rpc/SessionConnection.h | 3 +-
iotdb-client/client-cpp/src/rpc/SessionImpl.h | 3 +-
.../client-cpp/src/rpc/ThriftConnection.cpp | 11 +-
iotdb-client/client-cpp/src/rpc/ThriftConnection.h | 6 +-
iotdb-client/client-cpp/src/session/Session.cpp | 27 +-
iotdb-client/client-cpp/src/session/SessionC.cpp | 69 ++
.../client-cpp/src/session/SessionPool.cpp | 17 +-
.../src/session/SslConfig.cpp} | 19 +-
.../client-cpp/src/session/TableSession.cpp | 5 +-
iotdb-client/client-cpp/test/CMakeLists.txt | 36 +-
.../client-cpp/test/cpp/RpcSslIotdbE2eTest.cpp | 194 +++++
iotdb-client/client-cpp/test/cpp/sessionIT.cpp | 3 +-
.../client-cpp/test/cpp/sessionUtilsTest.cpp | 18 +-
iotdb-client/client-cpp/test/fixtures/tls/ca.crt | 19 +
.../client-cpp/test/fixtures/tls/client.crt | 17 +
.../client-cpp/test/fixtures/tls/client.key | 28 +
.../client-cpp/test/fixtures/tls/tls-server.p12 | Bin 0 -> 2608 bytes
.../test/main_rpc_ssl.cpp} | 4 +-
.../test/scripts/configure_iotdb_ssl_it.py | 117 +++
.../client-cpp/test/scripts/run_cpp_it_phases.py | 130 +++
iotdb-client/client-cpp/third-party/README.md | 6 +-
.../client-py/iotdb/utils/SessionDataSet.py | 30 +-
.../client-py/iotdb/utils/iotdb_rpc_dataset.py | 90 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 90 ++
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 10 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 5 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 19 +
.../apache/iotdb/session/SessionConnection.java | 26 +
.../iotdb/session/SessionConnectionTest.java | 19 +
.../subscription/i18n/SubscriptionMessages.java | 2 +
.../subscription/i18n/SubscriptionMessages.java | 2 +
.../SubscriptionSessionConnection.java | 8 +
.../base/AbstractSubscriptionConsumer.java | 37 +-
.../base/AbstractSubscriptionProvider.java | 96 ++-
.../base/AbstractSubscriptionProviders.java | 62 +-
.../base/AbstractSubscriptionPullConsumer.java | 86 +-
.../base/AbstractSubscriptionPushConsumer.java | 20 +-
.../SubscriptionSessionConnectionTimeoutTest.java | 148 ++++
.../SubscriptionConsumerConnectionFailureTest.java | 167 ++++
.../base/SubscriptionConsumerLifecycleTest.java | 96 ++-
iotdb-core/ainode/ainode.xml | 6 +-
.../iotdb/ainode/core/model/chronos2/__init__.py | 2 +
.../iotdb/ainode/core/model/chronos2/base.py | 3 +
.../ainode/core/model/chronos2/chronos_bolt.py | 3 +
.../iotdb/ainode/core/model/chronos2/config.py | 3 +
.../iotdb/ainode/core/model/chronos2/dataset.py | 3 +
.../iotdb/ainode/core/model/chronos2/layers.py | 3 +
.../iotdb/ainode/core/model/chronos2/model.py | 3 +
.../core/model/chronos2/pipeline_chronos2.py | 3 +
.../iotdb/ainode/core/model/chronos2/utils.py | 3 +
.../iotdb/ainode/core/model/moirai2/__init__.py | 6 +-
.../ainode/core/model/moirai2/common/torch_util.py | 5 +
.../ainode/core/model/moirai2/modeling_moirai2.py | 5 +
.../ainode/core/model/moirai2/module/attention.py | 5 +
.../iotdb/ainode/core/model/moirai2/module/ffn.py | 5 +
.../iotdb/ainode/core/model/moirai2/module/norm.py | 5 +
.../core/model/moirai2/module/packed_scaler.py | 5 +
.../core/model/moirai2/module/position/__init__.py | 5 +
.../core/model/moirai2/module/position/additive.py | 5 +
.../model/moirai2/module/position/attn_bias.py | 5 +
.../moirai2/module/position/attn_projection.py | 5 +
.../core/model/moirai2/module/transformer.py | 5 +
.../ainode/core/model/moirai2/module/ts_embed.py | 5 +
.../ainode/core/model/moirai2/transform/_base.py | 5 +
.../ainode/core/model/moirai2/transform/_mixin.py | 5 +
.../core/model/moirai2/transform/imputation.py | 5 +
.../core/model/moment/configuration_moment.py | 1 +
.../ainode/core/model/moment/modeling_moment.py | 1 +
.../ainode/core/model/moment/pipeline_moment.py | 1 +
.../iotdb/ainode/core/model/sundial/flow_loss.py | 80 +-
.../ainode/src/assembly/resources/NOTICE-binary | 65 ++
.../src/assembly/resources/licenses/LICENSE-GLIDE | 6 +-
.../src/assembly/resources/licenses/LICENSE-MOMENT | 6 +-
iotdb-core/ainode/tests/test_sundial_flow_loss.py | 123 +++
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../iotdb/confignode/i18n/ManagerMessages.java | 8 +
.../iotdb/confignode/i18n/ManagerMessages.java | 8 +
.../response/pipe/task/PipeTableResp.java | 8 +-
.../iotdb/confignode/manager/ProcedureManager.java | 31 +-
.../manager/partition/PartitionManager.java | 21 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 13 +
.../pipe/agent/task/PipeConfigNodeTask.java | 10 +
.../pipe/agent/task/PipeConfigNodeTaskStage.java | 10 +
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 76 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 1 +
.../persistence/subscription/SubscriptionInfo.java | 8 +-
.../runtime/CommitProgressSyncProcedure.java | 17 +-
.../ProcedureManagerReconstructRegionTest.java | 169 ++++
.../pipe/sink/PipeConfigNodeThriftRequestTest.java | 8 +-
.../runtime/CommitProgressSyncProcedureTest.java | 60 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 9 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 6 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 9 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 4 +
.../iotdb/db/i18n/StorageEngineMessages.java | 2 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 42 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 42 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 87 +-
...n.java => LoadAnalyzeInvalidPathException.java} | 5 +-
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 10 +
.../pipe/agent/task/stage/PipeTaskSinkStage.java | 12 +
.../agent/task/subtask/sink/PipeSinkSubtask.java | 84 +-
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 10 +
.../task/subtask/sink/PipeSinkSubtaskManager.java | 32 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 67 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 513 ++++++++---
.../TsFileInsertionEventParserMemoryManager.java | 14 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 232 ++++-
.../db/pipe/resource/memory/PipeMemoryManager.java | 123 +--
.../resource/tsfile/PipeTsFilePublicResource.java | 125 +--
.../resource/tsfile/PipeTsFileResourceManager.java | 72 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 7 +
.../evolvable/batch/PipeTabletEventBatch.java | 98 ++-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 86 +-
.../batch/PipeTabletEventTsFileBatch.java | 110 ++-
.../batch/PipeTransferBatchReqBuilder.java | 95 ++-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 1 +
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 13 +-
.../airgap/IoTDBSchemaRegionAirGapSink.java | 2 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 12 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 560 ++++++++----
.../PipeTransferTabletBatchEventHandler.java | 2 +-
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../handler/PipeTransferTrackableHandler.java | 94 +-
.../async/handler/PipeTransferTsFileHandler.java | 161 ++--
.../thrift/sync/IoTDBDataRegionSyncSink.java | 13 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 6 +-
.../sink/protocol/writeback/WriteBackSink.java | 101 ++-
.../util/builder/PipeTableModelTsFileBuilder.java | 41 +
.../builder/PipeTableModelTsFileBuilderV2.java | 45 +
.../util/builder/PipeTreeModelTsFileBuilder.java | 31 +
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 38 +
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 10 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 5 +
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 64 +-
.../db/queryengine/common/MPPQueryContext.java | 56 +-
.../common/header/DatasetHeaderFactory.java | 4 +
.../source/PipeReceiverRuntimeSnapshotFilter.java | 63 ++
...iesOperator.java => ShowReceiversOperator.java} | 115 +--
.../InformationSchemaContentSupplierFactory.java | 54 ++
.../metric/SeriesScanCostMetricSet.java | 18 +-
.../db/queryengine/plan/analyze/Analysis.java | 2 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 29 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 24 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 20 +-
.../queryengine/plan/execution/QueryExecution.java | 18 +-
.../config/executor/ClusterConfigTaskExecutor.java | 21 +-
.../metadata/relational/ShowCreatePipeTask.java | 7 +-
.../ConcatDeviceAndBindSchemaForHavingVisitor.java | 14 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 6 +
.../plan/planner/LocalExecutionPlanner.java | 10 +-
.../plan/planner/LogicalPlanBuilder.java | 39 +
.../plan/planner/LogicalPlanVisitor.java | 7 +
.../plan/planner/OperatorTreeGenerator.java | 26 +
.../SimpleFragmentParallelPlanner.java | 2 +
.../memory/OperatorMemoryNotEnoughException.java} | 24 +-
.../plan/node/DataNodePlanNodeDeserializer.java | 3 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
...ShowQueriesNode.java => ShowReceiversNode.java} | 47 +-
.../relational/analyzer/StatementAnalyzer.java | 16 +
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 3 +-
.../spill/AbstractDeviceEntryMaterializer.java | 5 +-
.../spill/DeviceEntrySortedMaterializer.java | 4 +-
.../metadata/spill/DeviceEntrySpillManager.java | 5 +
.../distribute/TableDistributedPlanGenerator.java | 10 +-
.../DataNodeLocationSupplierFactory.java | 1 +
.../security/TreeAccessCheckVisitor.java | 13 +-
.../plan/relational/sql/parser/AstBuilder.java | 11 +
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 5 +
...eStatement.java => ShowReceiversStatement.java} | 51 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +-
.../memtable/AlignedWritableMemChunk.java | 253 ++++++
.../dataregion/wal/buffer/AbstractWALBuffer.java | 39 +-
.../dataregion/wal/buffer/WALBuffer.java | 81 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 39 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 5 +-
.../load/LoadTsFilePathUtils.java} | 47 +-
.../converter/LoadTreeTsFileTabletIterator.java | 26 +-
.../broker/ConsensusSubscriptionBroker.java | 171 +++-
.../consensus/ConsensusPrefetchingQueue.java | 18 +-
.../task/stage/SubscriptionTaskSinkStage.java | 10 +
.../task/subtask/SubscriptionSinkSubtask.java | 5 +-
.../db/utils/datastructure/AlignedTVList.java | 49 ++
.../db/utils/datastructure/BackAlignedTVList.java | 1 +
.../db/utils/datastructure/QuickAlignedTVList.java | 1 +
.../iotdb/db/utils/datastructure/TVList.java | 6 +-
.../db/utils/datastructure/TimAlignedTVList.java | 3 +-
.../org/apache/iotdb/db/conf/PropertiesTest.java | 34 +-
.../subtask/sink/PipeSinkSubtaskLifeCycleTest.java | 58 ++
.../task/subtask/sink/PipeSinkSubtaskTest.java | 123 ++-
.../persist/PageCacheDeletionBufferTest.java | 88 ++
.../pipe/event/TsFileInsertionEventParserTest.java | 62 ++
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 138 +++
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 155 ++++
.../memory/PipeMemoryManagerResizeTest.java | 54 ++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 8 +-
.../iotdb/db/pipe/sink/PipeReceiverTest.java | 12 +-
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 60 ++
.../batch/PipeTabletEventTsFileBatchTest.java | 1 +
.../batch/PipeTransferBatchReqBuilderTest.java | 135 +++
.../handler/PipeTransferTrackableHandlerTest.java | 140 +++
.../PipeTransferTsFileHandlerCleanupTest.java | 23 +-
.../db/protocol/client/ConfigNodeInfoTest.java | 75 ++
.../db/queryengine/common/MPPQueryContextTest.java | 58 ++
.../operator/source/ShowReceiversOperatorTest.java | 571 +++++++++++++
.../InformationSchemaReceiversSupplierTest.java | 406 +++++++++
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 16 +-
.../metadata/relational/ShowCreateTaskTest.java | 46 +-
.../plan/parser/StatementGeneratorTest.java | 28 +
.../planner/node/source/SourceNodeSerdeTest.java | 11 +
.../plan/relational/analyzer/AuthTest.java | 51 ++
.../spill/DeviceEntryMaterializerTest.java | 16 +-
.../informationschema/ShowReceiversTest.java | 128 +++
.../memtable/AlignedTVListIteratorTest.java | 86 ++
.../dataregion/memtable/MemTableFlushTaskTest.java | 264 ++++++
.../memtable/NonAlignedTVListIteratorTest.java | 72 ++
.../wal/buffer/WALBufferRollRecoveryTest.java | 300 +++++++
.../dataregion/wal/io/WALFileTest.java | 15 +
.../load/converter/LoadTsFileInvalidPathTest.java | 195 +++++
.../ConsensusSubscriptionBrokerOwnershipTest.java | 192 +++++
.../consensus/ConsensusPrefetchingQueueTest.java | 54 ++
.../db/utils/datastructure/AlignedTVListTest.java | 32 +
.../conf/iotdb-system.properties.template | 12 +
.../agent/plugin/builtin/BuiltinPipePlugin.java | 33 +
.../iotdb/commons/pipe/agent/task/PipeTask.java | 8 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 24 +-
.../pipe/agent/task/stage/PipeTaskStage.java | 8 +
.../task/subtask/PipeAbstractSinkSubtask.java | 3 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 95 +++
.../runtime/PipeReceiverRuntimeRegistry.java | 355 ++++++++
.../runtime/PipeReceiverRuntimeSnapshot.java | 115 +++
.../pipe/sink/client/IoTDBClientManager.java | 25 +
.../pipe/sink/client/IoTDBSyncClientManager.java | 110 ++-
.../common/PipeTransferHandshakeConstant.java | 2 +
.../payload/thrift/request/PipeRequestType.java | 3 +
.../thrift/request/PipeTransferHandshakeV1Req.java | 3 +-
.../thrift/request/PipeTransferHandshakeV2Req.java | 8 +-
...eTransferPipeReceiverRuntimeInfoCleanupReq.java | 103 +++
.../commons/pipe/sink/protocol/IoTDBSink.java | 27 +
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 22 +
.../plan/planner/plan/node/PlanNodeType.java | 1 +
.../schema/column/ColumnHeaderConstant.java | 42 +
.../commons/schema/table/InformationSchema.java | 34 +
.../meta/consumer/ConsumerGroupMeta.java | 31 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 27 +
.../runtime/PipeReceiverRuntimeRegistryTest.java | 947 +++++++++++++++++++++
.../thrift/request/PipeRequestTypeTest.java | 25 +
.../commons/pipe/task/PipeSleepIntervalTest.java | 17 +
.../consumer/ConsumerGroupDeSerTest.java | 26 +
.../apache/iotdb/commons/utils/FileUtilsTest.java | 12 +
.../db/relational/grammar/sql/RelationalSql.g4 | 8 +-
pom.xml | 9 +-
scripts/sbin/windows/start-confignode.bat | 4 +-
scripts/sbin/windows/start-datanode.bat | 4 +-
scripts/sbin/windows/start-standalone.bat | 7 +-
310 files changed, 14183 insertions(+), 2483 deletions(-)
copy distribution/src/assembly/{common-files.xml => ainode-common-files.xml}
(85%)
delete mode 100644 distribution/src/assembly/cli.xml
delete mode 100644 distribution/src/assembly/confignode.xml
delete mode 100644 distribution/src/assembly/datanode.xml
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeRelationalSecurityIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBShowReceiversLifecycleIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBLegacyPipeReceiverSecurityIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeReceiverIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBShowReceiversIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/triple/IoTDBShowReceiversTripleIT.java
copy iotdb-client/client-cpp/src/include/{Status.h => SslConfig.h} (75%)
copy
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/SimpleEnv.java
=> iotdb-client/client-cpp/src/rpc/RpcSslUtils.cpp (59%)
copy
iotdb-client/{isession/src/main/java/org/apache/iotdb/isession/ISessionDataSet.java
=> client-cpp/src/rpc/RpcSslUtils.h} (69%)
copy
iotdb-client/{service-rpc/src/main/java/org/apache/iotdb/rpc/NoValidValueException.java
=> client-cpp/src/session/SslConfig.cpp} (66%)
create mode 100644 iotdb-client/client-cpp/test/cpp/RpcSslIotdbE2eTest.cpp
create mode 100644 iotdb-client/client-cpp/test/fixtures/tls/ca.crt
create mode 100644 iotdb-client/client-cpp/test/fixtures/tls/client.crt
create mode 100644 iotdb-client/client-cpp/test/fixtures/tls/client.key
create mode 100644 iotdb-client/client-cpp/test/fixtures/tls/tls-server.p12
copy iotdb-client/{jdbc/src/main/resources/services/META-INF/java.sql.Driver
=> client-cpp/test/main_rpc_ssl.cpp} (94%)
create mode 100644
iotdb-client/client-cpp/test/scripts/configure_iotdb_ssl_it.py
create mode 100644 iotdb-client/client-cpp/test/scripts/run_cpp_it_phases.py
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/SubscriptionSessionConnectionTimeoutTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerConnectionFailureTest.java
create mode 100644 iotdb-core/ainode/src/assembly/resources/NOTICE-binary
copy licenses/The MIT License (progressbar) =>
iotdb-core/ainode/src/assembly/resources/licenses/LICENSE-GLIDE (93%)
copy licenses/The MIT License (progressbar) =>
iotdb-core/ainode/src/assembly/resources/licenses/LICENSE-MOMENT (92%)
create mode 100644 iotdb-core/ainode/tests/test_sundial_flow_loss.py
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerReconstructRegionTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/load/{LoadAnalyzeMissingSchemaException.java
=> LoadAnalyzeInvalidPathException.java} (80%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/PipeReceiverRuntimeSnapshotFilter.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/{ShowQueriesOperator.java
=> ShowReceiversOperator.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/compaction/execute/exception/CompactionMemoryNotEnoughException.java
=> queryengine/plan/planner/memory/OperatorMemoryNotEnoughException.java} (56%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/{ShowQueriesNode.java
=> ShowReceiversNode.java} (64%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{ShowDiskUsageStatement.java
=> ShowReceiversStatement.java} (58%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{schemaengine/schemaregion/read/resp/info/impl/ShowSchemaResult.java
=> storageengine/load/LoadTsFilePathUtils.java} (50%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskLifeCycleTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/consensus/deletion/persist/PageCacheDeletionBufferTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeTransferBatchReqBuilderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/client/ConfigNodeInfoTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/ShowReceiversOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/InformationSchemaReceiversSupplierTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/informationschema/ShowReceiversTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/buffer/WALBufferRollRecoveryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/LoadTsFileInvalidPathTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBrokerOwnershipTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/runtime/PipeReceiverRuntimeRegistry.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/runtime/PipeReceiverRuntimeSnapshot.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferPipeReceiverRuntimeInfoCleanupReq.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/receiver/runtime/PipeReceiverRuntimeRegistryTest.java
