This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch feat/pipe-logical-backup-sink
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 218dcb43001 Harden logical backup failover and import recovery
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 87a6d198a90 Allow removing regions from read-only DataNodes (#18670)
add 7310b2bc0eb Fix oversized Load TsFile piece dispatch (#18627)
add 6709dfa9494 Fix concurrent subscription consumer handshakes (#18654)
add 0862ecb1d1c Fix Surefire fork port isolation (#18676)
add 957204481d9 Fragment large TsBlocks in MPP DataExchange responses
(#18645)
add d2fcb5383ab Fix delayed query cleanup during file metadata scans
(#18679)
add 61f2014ded8 Fix client manager metrics and JMX lifecycle races (#18681)
add f46d5da261c Merge branch 'master' of https://github.com/apache/iotdb
into feat/pipe-logical-backup-sink
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 +-
distribution/pom.xml | 6 -
distribution/src/assembly/cli.xml | 76 --
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 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 9 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 6 +-
.../it/env/remote/config/RemoteDataNodeConfig.java | 6 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 2 +
.../IoTDBAutoRegionGroupExtension2IT.java | 4 +-
.../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 +++++
.../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 ++
...AbstractIoTDBMPPDataExchangeLargeTsBlockIT.java | 98 +++
.../IoTDBMPPDataExchangeLargeTsBlock128KIT.java} | 18 +-
.../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 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../apache/iotdb/session/SessionConnection.java | 26 +
.../iotdb/session/SessionConnectionTest.java | 19 +
.../subscription/i18n/SubscriptionMessages.java | 2 +
.../subscription/i18n/SubscriptionMessages.java | 2 +
.../rpc/subscription/config/ConsumerConfig.java | 4 +
.../rpc/subscription/config/ConsumerConstant.java | 1 +
...va => SubscriptionConsumerFencedException.java} | 18 +-
.../SubscriptionSessionConnection.java | 8 +
.../base/AbstractSubscriptionConsumer.java | 235 +++--
.../base/AbstractSubscriptionProvider.java | 113 ++-
.../base/AbstractSubscriptionProviders.java | 117 ++-
.../base/AbstractSubscriptionPullConsumer.java | 100 ++-
.../base/AbstractSubscriptionPushConsumer.java | 24 +-
.../SubscriptionSessionConnectionTimeoutTest.java | 148 ++++
.../SubscriptionConsumerConnectionFailureTest.java | 167 ++++
.../base/SubscriptionConsumerLifecycleTest.java | 376 +++++++-
.../base/SubscriptionProviderStatusTest.java | 72 ++
.../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 +
.../iotdb/confignode/manager/ProcedureManager.java | 59 +-
.../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 +-
.../ProcedureManagerReconstructRegionTest.java | 190 +++++
.../pipe/sink/PipeConfigNodeThriftRequestTest.java | 8 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 12 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 6 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 31 +
.../iotdb/db/i18n/StorageEngineMessages.java | 17 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 12 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 6 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 30 +
.../iotdb/db/i18n/StorageEngineMessages.java | 19 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 42 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 24 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 96 ++-
.../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 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 232 ++++-
.../client/IoTDBDataNodeAsyncClientManager.java | 7 +
.../evolvable/batch/PipeTabletEventBatch.java | 7 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 1 +
.../airgap/IoTDBSchemaRegionAirGapSink.java | 2 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 29 +
.../thrift/sync/IoTDBSchemaRegionSink.java | 6 +-
.../sink/protocol/writeback/WriteBackSink.java | 101 ++-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 5 +
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 64 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 41 +-
.../db/queryengine/common/MPPQueryContext.java | 47 +-
.../common/header/DatasetHeaderFactory.java | 4 +
.../execution/exchange/MPPDataExchangeManager.java | 44 +
.../execution/exchange/sink/SinkChannel.java | 49 +-
.../execution/exchange/source/SourceHandle.java | 158 +++-
.../source/PipeReceiverRuntimeSnapshotFilter.java | 63 ++
.../execution/operator/source/SeriesScanUtil.java | 24 +
...iesOperator.java => ShowReceiversOperator.java} | 115 +--
.../InformationSchemaContentSupplierFactory.java | 54 ++
.../db/queryengine/plan/analyze/Analysis.java | 2 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 29 +
.../config/executor/ClusterConfigTaskExecutor.java | 21 +-
.../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 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 3 +-
.../distribute/TableDistributedPlanGenerator.java | 10 +-
.../DataNodeLocationSupplierFactory.java | 1 +
.../security/TreeAccessCheckVisitor.java | 13 +-
.../plan/relational/sql/parser/AstBuilder.java | 11 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 169 +++-
.../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 +-
.../iotdb/db/storageengine/StorageEngine.java | 32 +
.../memtable/AlignedWritableMemChunk.java | 8 +
.../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 +-
.../db/storageengine/load/LoadTsFileManager.java | 67 +-
.../load/LoadTsFilePieceNodeAssembler.java | 170 ++++
.../agent/SubscriptionReceiverAgent.java | 86 +-
.../broker/ConsensusSubscriptionBroker.java | 171 +++-
.../consensus/ConsensusPrefetchingQueue.java | 18 +-
.../receiver/SubscriptionReceiver.java | 8 +
.../receiver/SubscriptionReceiverV1.java | 42 +-
.../task/stage/SubscriptionTaskSinkStage.java | 10 +
.../task/subtask/SubscriptionSinkSubtask.java | 5 +-
.../iotdb/db/utils/datastructure/TVList.java | 6 +-
.../org/apache/iotdb/db/conf/PropertiesTest.java | 43 +-
.../subtask/sink/PipeSinkSubtaskLifeCycleTest.java | 58 ++
.../task/subtask/sink/PipeSinkSubtaskTest.java | 123 ++-
.../persist/PageCacheDeletionBufferTest.java | 88 ++
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 138 +++
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 155 ++++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 8 +-
.../iotdb/db/pipe/sink/PipeReceiverTest.java | 12 +-
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 57 ++
.../batch/PipeTransferBatchReqBuilderTest.java | 25 +
.../db/protocol/client/ConfigNodeInfoTest.java | 75 ++
.../DataNodeInternalRPCServiceImplLoadTest.java | 94 ++
.../db/queryengine/common/MPPQueryContextTest.java | 58 ++
.../execution/exchange/SinkChannelTest.java | 16 +-
.../execution/exchange/SourceHandleTest.java | 185 +++-
.../db/queryengine/execution/exchange/Utils.java | 7 +
.../source/SeriesScanUtilCancellationTest.java | 399 +++++++++
.../operator/source/ShowReceiversOperatorTest.java | 571 +++++++++++++
.../InformationSchemaReceiversSupplierTest.java | 406 +++++++++
.../plan/parser/StatementGeneratorTest.java | 28 +
.../planner/node/source/SourceNodeSerdeTest.java | 11 +
.../plan/relational/analyzer/AuthTest.java | 51 ++
.../informationschema/ShowReceiversTest.java | 128 +++
.../load/LoadTsFileDispatcherImplTest.java | 225 +++++
.../memtable/AlignedTVListIteratorTest.java | 86 ++
.../dataregion/memtable/MemTableFlushTaskTest.java | 74 ++
.../memtable/NonAlignedTVListIteratorTest.java | 72 ++
.../wal/buffer/WALBufferRollRecoveryTest.java | 300 +++++++
.../dataregion/wal/io/WALFileTest.java | 15 +
.../load/LoadTsFilePieceNodeAssemblerTest.java | 215 +++++
.../agent/SubscriptionReceiverAgentTest.java | 361 +++++++-
.../ConsensusSubscriptionBrokerOwnershipTest.java | 192 +++++
.../consensus/ConsensusPrefetchingQueueTest.java | 54 ++
.../receiver/SubscriptionReceiverV1Test.java | 41 +
iotdb-core/metrics/core/pom.xml | 5 +
.../metrics/core/reporter/IoTDBJmxReporter.java | 115 ++-
.../iotdb/metrics/core/type/IoTDBAutoGauge.java | 5 +-
.../core/utils/IoTDBMetricObjNameFactory.java | 38 +-
.../metrics/core/utils/ObjectNameFactory.java | 45 +
.../metrics/core/MetricManagerLifecycleTest.java | 339 ++++++++
.../core/reporter/IoTDBJmxReporterTest.java | 205 +++++
.../metrics/core/type/IoTDBAutoGaugeTest.java | 68 ++
.../core/utils/IoTDBMetricObjNameFactoryTest.java | 123 +++
.../iotdb/metrics/AbstractMetricManager.java | 215 +++--
.../conf/iotdb-system.properties.template | 7 +
.../apache/iotdb/commons/i18n/ClientMessages.java | 3 +
.../apache/iotdb/commons/i18n/ClientMessages.java | 3 +
.../commons/audit/UserDataTransferErrorCode.java | 3 +-
.../apache/iotdb/commons/client/ClientManager.java | 19 +-
.../iotdb/commons/client/ClientManagerMetrics.java | 200 +++--
.../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 +-
.../commons/client/ClientManagerMetricsTest.java | 580 +++++++++++++
.../runtime/PipeReceiverRuntimeRegistryTest.java | 947 +++++++++++++++++++++
.../thrift/request/PipeRequestTypeTest.java | 25 +
.../commons/pipe/task/PipeSleepIntervalTest.java | 17 +
.../service/metric/MetricReporterSwitchTest.java | 166 ++++
.../consumer/ConsumerGroupDeSerTest.java | 26 +
.../db/relational/grammar/sql/RelationalSql.g4 | 8 +-
.../src/main/thrift/datanode.thrift | 11 +
pom.xml | 10 +-
scripts/sbin/windows/start-confignode.bat | 4 +-
scripts/sbin/windows/start-datanode.bat | 4 +-
scripts/sbin/windows/start-standalone.bat | 7 +-
265 files changed, 15535 insertions(+), 2187 deletions(-)
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
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/AbstractIoTDBMPPDataExchangeLargeTsBlockIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBAlignByDeviceWithTemplateTable2IT.java
=> recent/IoTDBMPPDataExchangeLargeTsBlock128KIT.java} (73%)
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
copy
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionIdentifierSemanticException.java
=> SubscriptionConsumerFencedException.java} (60%)
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-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionProviderStatusTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerReconstructRegionTest.java
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%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFilePieceNodeAssembler.java
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/protocol/client/ConfigNodeInfoTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplLoadTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/SeriesScanUtilCancellationTest.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/LoadTsFilePieceNodeAssemblerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBrokerOwnershipTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/MetricManagerLifecycleTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/reporter/IoTDBJmxReporterTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/type/IoTDBAutoGaugeTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/utils/IoTDBMetricObjNameFactoryTest.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/client/ClientManagerMetricsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/receiver/runtime/PipeReceiverRuntimeRegistryTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/MetricReporterSwitchTest.java
