This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch fix/consensus-subscription-read-frontiers
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f30b5c5aeaa Clarify ordered WAL scan budget accounting
add ecf526ad73a Python: fix swapped session and statement IDs in query
result sets (#18842)
add 27f89fa72fc [Feature] Make DROP TABLE asynchronous and expose deletion
progress (#18806)
add c179b0cd4ed [Session] Throw IoTDBConnectionException instead of NPE
when retries are exhausted (#18794)
add a78f5a736c7 [Performance] Pre-size collections with known cardinality
add 491d9b3590b [Test] Stabilize table DDL HA tests for async DROP TABLE
(#18852)
add 426376b1955 [Storage] Replace IDeviceID.isTableModel with the data
model from context (#18814)
add 510fc7c4544 Fix subscription initialization retries for transient WAL
reads (#18829)
add 3d57d2507fa [Subscription] Preserve WAL replay progress across pending
gaps (#18831)
add a7e508cf458 [Subscription] Index consensus ACK progress by writer
(#18835)
add 030bedd2b2b Fix DATE conversion beyond tablet row count (#18832)
add 72b4d16ac6d [Test] Fix AlignedWritableMemChunkTest compilation error
(#18859)
add aec1ad6139c [Pipe] Wake parser workers when admission is available
(#18843)
add 0a79a4925e9 Fix flaky space quota result polling in cluster tests
(#18850)
add a498d7d2a46 Fix schema mutation validation, accounting and deletion
performance (#18861)
add edd5a74c42d Prevent query with explict limit 0 (#18858)
add 0c0116afe22 Bound consensus subscription WAL scans per prefetch round
(#18849)
add 6eca5b841d7 [Pipe] Add SHOW PIPE MEMORY for named memory blocks
(#18575)
add 8effe5d6ce4 Support retaining subscription progress after unsubscribe
(#18718)
add db8bc17a27f [Feature] Expose DROP TABLE mod file progress (#18855)
add 5842fbc6a7b [Pipe] Add reliable DataNode completion metric (#18563)
add 3f1706cbce0 Fix subscription realtime retention under shared memory
pressure (#18870)
add f106a0f1d16 [Test] Wait for asynchronous table deletion in session IT
(#18877)
add 1b290ae320c [Bugfix] Reclaim RPC buffers by evicting idle clients
(#18853)
add ed61790920d [Test] Fix pipe memory ownership test compilation (#18881)
add f8135bb7284 [Test] Fix Ratis mini-cluster shutdown race (#18879)
add e3bbab5e7e8 [Subscription] Support per-topic uncommitted event recycle
timeouts (#18876)
add e1baa97f2db [Fix] Stop only the listening DataNode process in Windows
stop-datanode.bat (#18883)
add d77a81534e3 Fix deletion WAL logging and flush completion ordering
(#18872)
add 673434b3335 Fix quoted tree path parsing in table views (#18884)
add 264053f1423 [Test] Fix deletion regression test flush control
add 532d6c13add Fence IoTConsensus applies before storage shutdown (#18841)
add 6402cd9594b Revert "[Test] Fix deletion regression test flush control"
add f660639add9 [Test] Exclude mock initialization from pipe worker
timeouts (#18886)
add a7b88b1027e [Test] Fix deletion regression test flush control (#18888)
add d2b97bc8455 Reuse DataRegion insert lock for IoTConsensus shutdown
fencing (#18893)
add 330b0c7ca41 [Test] Fix relational session cleanup and invalid
timestamp test setup (#18887)
add aa365aa53f1 [Client] Add Fast Last Query API to C++ session (#18860)
add e492e444a8d [Fix] Preserve table insert errors for rejected fields
(#18880)
add 9b807abb93f [Bugfix] Preserve retained subscription progress after the
last consumer closes (#18894)
add 9a078cc105e [Subscription] Fix WAL replay progress after realtime gaps
(#18895)
add 4e9679da812 feat: support automatic schema creation in Session (#18890)
add 62337565abc feat(load): route decoded tsfile pieces through consensus
(#18698)
add c6f86b52a94 [Subscription] Release uncommitted tablet payloads with
WAL replay (#18866)
add bacbd5a6dc4 Fix ConfigNode client failover with stale candidates
(#18847)
add c9c16af42f6 [Test] Fix dynamic status queries and asynchronous
deletion polling (#18899)
add d1aaa0dd909 Optimize errMsg when set configuration default- #18856
add 879dcc8266a Merge origin/master into PR #18844
No new revisions were added by this update.
Summary of changes:
.../it/cluster/IoTDBNodeStatusFailoverIT.java | 21 +-
.../iotdb/db/it/IoTDBLoadTsFileClusterIT.java | 383 ++++
.../apache/iotdb/db/it/IoTDBShowPipeMemoryIT.java | 246 +++
.../iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java | 5 +
.../apache/iotdb/db/it/utils/IoTDBTestUtilsIT.java | 129 ++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 123 +-
.../manual/basic/IoTDBPipePermissionIT.java | 8 +-
.../manual/basic/IoTDBPipeWithLoadIT.java | 3 +-
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 71 +-
.../manual/enhanced/IoTDBPipeClusterIT.java | 41 +-
.../manual/enhanced/IoTDBPipeMetaIT.java | 20 +-
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 6 +-
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 105 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 38 +-
.../treemodel/manual/IoTDBPipeInclusionIT.java | 26 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 6 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 12 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 4 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 62 +
.../it/db/it/IoTDBSetConfigurationTableIT.java | 11 +
.../it/insertquery/IoTDBInsertQueryIT.java | 3 +-
.../it/query/old/IoTDBSimpleQueryTableIT.java | 24 +
.../relational/it/query/recent/IoTDBCteIT.java | 5 +-
.../it/query/recent/IoTExplainAnalyzeIT.java | 5 +-
.../query/view/recent/IoTDBTableViewQueryIT.java | 2 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 72 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 13 +-
.../it/schema/IoTDBDropTableModProgressIT.java | 106 ++
.../relational/it/schema/IoTDBTableDDLHAIT.java | 21 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 65 +-
.../it/session/IoTDBSessionRelationalIT.java | 139 +-
.../IoTDBConsensusSubscriptionBasicTableIT.java | 60 +
.../org/apache/iotdb/pipe/api/event/Event.java | 18 +-
iotdb-client/client-cpp/src/include/Session.h | 5 +
.../client-cpp/src/rpc/SessionConnection.cpp | 38 +
.../client-cpp/src/rpc/SessionConnection.h | 3 +
iotdb-client/client-cpp/src/session/Session.cpp | 5 +
iotdb-client/client-cpp/test/cpp/sessionIT.cpp | 47 +
iotdb-client/client-py/iotdb/Session.py | 128 +-
.../client-py/tests/unit/test_session_query_ids.py | 132 ++
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 8 +-
.../iotdb/session/AbstractSessionBuilder.java | 2 +
.../java/org/apache/iotdb/session/Session.java | 29 +-
.../apache/iotdb/session/SessionConnection.java | 25 +-
.../apache/iotdb/session/TableSessionBuilder.java | 12 +
.../org/apache/iotdb/session/pool/SessionPool.java | 5 +
.../session/pool/TableSessionPoolBuilder.java | 12 +
.../apache/iotdb/session/util/SessionUtils.java | 2 +-
.../iotdb/session/BrokenSessionConnectionTest.java | 222 +++
.../iotdb/session/SessionCacheLeaderTest.java | 79 +-
.../iotdb/rpc/subscription/config/TopicConfig.java | 19 +
.../rpc/subscription/config/TopicConstant.java | 7 +
.../rpc/subscription/config/TopicConfigTest.java | 34 +
.../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 +
.../SimpleTsBlockWithPositionComparator.java | 2 +-
.../operator/process/FilterAndProjectOperator.java | 6 +-
.../process/PatternRecognitionOperator.java | 2 +-
.../rowpattern/PatternPartitionExecutor.java | 2 +-
.../process/rowpattern/expression/Computation.java | 2 +-
.../rowpattern/expression/NaryComputation.java | 2 +-
.../AbstractCaseWhenThenColumnTransformer.java | 2 +-
.../multi/LogicalAndMultiColumnTransformer.java | 2 +-
.../multi/LogicalOrMultiColumnTransformer.java | 2 +-
.../dag/column/multi/MultiColumnTransformer.java | 2 +-
.../apache/iotdb/calc/utils/sort/DiskSpiller.java | 4 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 9 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 9 +
.../client/async/CnToDnAsyncRequestType.java | 1 +
.../CnToDnInternalServiceAsyncRequestManager.java | 15 +-
.../rpc/DataNodeAsyncRequestRPCHandler.java | 9 +
...java => GetDropTableModProgressRPCHandler.java} | 37 +-
.../request/write/auth/AuthorTreePlan.java | 4 +-
.../pipe/payload/PipeDeactivateTemplatePlan.java | 4 +-
.../pipe/task/OperateMultiplePipesPlanV2.java | 2 +-
.../topic/AlterMultipleTopicsPlan.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 10 +
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/ProcedureManager.java | 110 +-
.../persistence/subscription/SubscriptionInfo.java | 152 +-
.../confignode/procedure/ProcedureExecutor.java | 106 +-
.../procedure/TimeoutExecutorThread.java | 2 +-
.../impl/schema/DeactivateTemplateProcedure.java | 3 +-
.../impl/schema/table/DropTableProcedure.java | 186 +-
.../impl/sync/AuthOperationProcedure.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
...ToDnInternalServiceAsyncRequestManagerTest.java | 114 ++
.../subscription/SubscriptionInfoTest.java | 224 +++
.../SubscriptionInfoTopicValidationTest.java | 150 ++
.../impl/schema/table/DropTableProcedureTest.java | 333 ++++
.../common/request/IndexedConsensusRequest.java | 20 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 15 +-
.../consensus/iot/IoTConsensusServerImpl.java | 62 +-
.../consensus/iot/log/ConsensusReqReader.java | 8 +
.../logdispatcher/IoTConsensusMemoryManager.java | 6 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 13 +-
.../subscription/SubscriptionQueueRegistry.java | 101 +-
.../request/IndexedConsensusRequestTest.java | 110 ++
.../consensus/iot/IoTConsensusServerImplTest.java | 94 +
.../SubscriptionQueueRegistryTest.java | 88 +
.../iotdb/consensus/ratis/RecoverReadTest.java | 70 +
.../apache/iotdb/consensus/ratis/TestUtils.java | 51 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 7 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 6 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 117 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 12 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 206 ++-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 7 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 6 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 116 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 12 +-
.../iotdb/db/i18n/StorageEngineMessages.java | 200 ++-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 19 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 12 +
.../dataregion/DataExecutionVisitor.java | 74 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 7 +-
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 6 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 87 +
.../task/builder/PipeDataNodeTaskBuilder.java | 1 +
.../agent/task/connection/PipeEventCollector.java | 23 +-
.../agent/task/stage/PipeTaskProcessorStage.java | 2 +
.../pipe/agent/task/stage/PipeTaskSourceStage.java | 18 +
.../subtask/processor/PipeProcessorSubtask.java | 14 +-
.../PipeProcessorSubtaskExecutionGuard.java | 16 +
.../processor/PipeProcessorSubtaskWorker.java | 29 +-
.../sink/PipeRealtimePriorityBlockingQueue.java | 4 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 11 +
.../db/pipe/event/common/PipeInsertionEvent.java | 9 +
.../event/common/heartbeat/PipeHeartbeatEvent.java | 102 +-
.../statement/PipeStatementInsertionEvent.java | 15 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 32 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 61 +-
.../event/common/terminate/PipeTerminateEvent.java | 5 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 45 +-
.../tsfile/parser/TsFileInsertionEventParser.java | 19 +-
.../TsFileInsertionEventParserMemoryManager.java | 68 +-
.../query/TsFileInsertionEventQueryParser.java | 12 +-
...ileInsertionEventQueryParserTabletIterator.java | 2 +-
.../scan/TsFileInsertionEventScanParser.java | 25 +-
.../table/TsFileInsertionEventTableParser.java | 19 +-
...ileInsertionEventTableParserTabletIterator.java | 7 +-
.../tsfile/parser/util/ModsOperationUtil.java | 24 +-
.../event/realtime/PipeRealtimeEventFactory.java | 4 +
.../overview/PipeDataNodeCompletionOperator.java | 420 +++++
.../PipeDataNodeRemainingEventAndTimeOperator.java | 4 +
.../overview/PipeDataNodeSinglePipeMetrics.java | 126 +-
.../pipe/metric/overview/PipeResourceMetrics.java | 47 +
.../downsampling/DownSamplingProcessor.java | 3 +
.../downsampling/PartialPathLastObjectCache.java | 13 +-
.../payload/FetchCombineResultRequest.java | 2 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 4 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 12 +-
.../pipe/resource/memory/PipeFixedMemoryBlock.java | 37 +-
.../db/pipe/resource/memory/PipeMemoryBlock.java | 282 ++-
...BlockType.java => PipeMemoryBlockCategory.java} | 34 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 955 ++++++++--
.../resource/memory/PipeModelFixedMemoryBlock.java | 27 +-
.../resource/memory/PipeTabletMemoryBlock.java | 14 +-
.../resource/memory/PipeTsFileMemoryBlock.java | 14 +-
.../resource/tsfile/PipeTsFilePublicResource.java | 29 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 8 +-
.../batch/PipeSchemaRegionWritePlanEventBatch.java | 9 +-
.../evolvable/batch/PipeTabletEventBatch.java | 9 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 7 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 7 +-
.../IoTConsensusV2TsFileInsertionEventHandler.java | 8 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 9 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 7 +-
.../async/handler/PipeTransferTsFileHandler.java | 8 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 7 +-
.../builder/PipeTableModelTsFileBuilderV2.java | 3 +-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 3 +-
.../source/dataregion/IoTDBDataRegionSource.java | 15 +
...istoricalDataRegionTsFileAndDeletionSource.java | 16 +-
.../PipeRealtimeDataRegionHybridSource.java | 20 +-
.../realtime/PipeRealtimeDataRegionLogSource.java | 1 +
.../realtime/PipeRealtimeDataRegionSource.java | 41 +-
.../PipeRealtimeDataRegionTsFileSource.java | 1 +
.../realtime/assigner/DisruptorQueue.java | 8 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 243 ++-
.../listener/PipeInsertionDataNodeListener.java | 77 +-
.../matcher/CachedSchemaPatternMatcher.java | 25 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../iotdb/db/protocol/session/IClientSession.java | 10 +
.../iotdb/db/protocol/session/SessionManager.java | 3 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 15 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 66 +-
.../db/queryengine/common/TimeseriesContext.java | 4 +-
.../fragment/FragmentInstanceContext.java | 4 +-
.../fragment/FragmentInstanceFailureInfo.java | 4 +-
.../execution/fragment/QueryContext.java | 12 +-
.../operator/process/TransformOperator.java | 2 +-
.../schema/source/DeviceBlackListConstructor.java | 14 +-
.../InformationSchemaContentSupplierFactory.java | 135 ++
.../iotdb/db/queryengine/plan/Coordinator.java | 23 +
.../plan/analyze/ClusterPartitionFetcher.java | 4 +
.../analyze/cache/partition/PartitionCache.java | 52 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 2 +-
.../analyze/load/LoadTsFileTreeSchemaCache.java | 6 +-
.../plan/expression/multi/FunctionExpression.java | 4 +-
.../visitor/ColumnTransformerVisitor.java | 6 +-
.../visitor/CompleteMeasurementSchemaVisitor.java | 2 +-
.../visitor/IntermediateLayerVisitor.java | 3 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 6 +
.../plan/node/DataNodePlanNodeDeserializer.java | 7 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/load/LoadPieceConsensusRequest.java | 117 ++
.../plan/node/load/LoadTsFileConsensusNode.java | 937 ++++++++++
.../plan/node/load/LoadTsFileConsensusOp.java | 60 +
.../plan/node/load/LoadTsFilePieceNode.java | 27 +-
.../metadata/read/LevelTimeSeriesCountNode.java | 4 +-
.../metadata/read/SeriesSchemaFetchScanNode.java | 4 +-
.../node/metadata/read/TimeSeriesCountNode.java | 4 +-
.../metadata/read/TimeSeriesSchemaScanNode.java | 4 +-
.../write/CreateAlignedTimeSeriesNode.java | 14 +-
.../plan/node/metadata/write/MeasurementGroup.java | 14 +-
.../planner/plan/node/sink/IdentitySinkNode.java | 2 +-
.../planner/plan/node/sink/ShuffleSinkNode.java | 2 +-
.../source/AlignedSeriesAggregationScanNode.java | 3 +-
.../plan/node/source/DeviceRegionScanNode.java | 3 +-
.../node/source/SeriesAggregationScanNode.java | 3 +-
.../plan/node/source/TimeseriesRegionScanNode.java | 10 +-
.../plan/node/write/InsertMultiTabletsNode.java | 5 +-
.../plan/planner/plan/node/write/InsertNode.java | 5 +
.../planner/plan/node/write/InsertRowsNode.java | 5 +-
.../plan/node/write/RelationalInsertRowsNode.java | 5 +-
.../parameter/model/ModelInferenceDescriptor.java | 4 +-
.../relational/analyzer/StatementAnalyzer.java | 4 +-
.../fetcher/TableHeaderSchemaValidator.java | 3 +-
.../TableDeviceAttributeCommitUpdateNode.java | 4 +-
.../DataNodeLocationSupplierFactory.java | 2 +
.../security/TreeAccessCheckVisitor.java | 10 +
.../plan/relational/sql/parser/AstBuilder.java | 35 +-
.../plan/scheduler/load/ChunkOffsetCalculator.java | 208 +++
.../scheduler/load/DataPartitionBatchFetcher.java | 154 ++
.../plan/scheduler/load/DataPartitionResolver.java | 100 ++
.../plan/scheduler/load/DataPartitionRouter.java | 144 ++
.../scheduler/load/LoadConsensusSubmitter.java | 262 +++
.../plan/scheduler/load/LoadFallbackHandler.java | 239 +++
.../scheduler/load/LoadTsFileDispatcherImpl.java | 553 +++---
.../plan/scheduler/load/LoadTsFileScheduler.java | 1292 +++++---------
.../plan/scheduler/load/LocalLoadStrategy.java | 241 +++
.../plan/scheduler/load/MemoryBoundedBuffer.java | 64 +
.../plan/scheduler/load/PieceDispatcher.java | 246 +++
.../plan/scheduler/load/TsFileLoadStrategy.java | 46 +
.../plan/scheduler/load/TsFileSplitConsumer.java | 163 ++
.../load/TwoPhaseConsensusLoadStrategy.java | 590 +++++++
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 5 +
.../ShowPipeMemoryStatement.java} | 41 +-
.../attribute/DeviceAttributeStore.java | 75 +-
.../visitor/SchemaRegionPlanDeserializer.java | 18 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 23 +-
.../impl/mem/mnode/impl/BasicInternalMNode.java | 60 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 1 +
.../schemaregion/utils/MetaFormatUtils.java | 23 +
.../schemaregion/utils/ResourceByPathUtils.java | 5 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +
.../iotdb/db/service/DataNodeShutdownHook.java | 3 +
.../iotdb/db/storageengine/StorageEngine.java | 127 +-
.../db/storageengine/dataregion/DataRegion.java | 391 ++++-
.../performer/impl/FastCompactionPerformer.java | 8 +-
.../impl/ReadChunkCompactionPerformer.java | 2 +-
.../impl/ReadPointCompactionPerformer.java | 2 +-
.../execute/utils/CompactionPathUtils.java | 10 +-
.../compaction/execute/utils/CompactionUtils.java | 15 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 45 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 6 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 2 +-
.../executor/fast/SeriesCompactionExecutor.java | 5 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 3 +-
.../selector/impl/SettleSelectorImpl.java | 7 +-
.../dataregion/flush/MemTableFlushTask.java | 22 +-
.../dataregion/memtable/AbstractMemTable.java | 62 +-
.../memtable/AbstractWritableMemChunk.java | 9 +-
.../memtable/AlignedWritableMemChunk.java | 60 +-
.../memtable/AlignedWritableMemChunkGroup.java | 37 +-
.../dataregion/memtable/IMemTable.java | 8 +-
.../dataregion/memtable/IWritableMemChunk.java | 14 +-
.../memtable/IWritableMemChunkGroup.java | 12 +-
.../dataregion/memtable/TsFileProcessor.java | 140 +-
.../dataregion/memtable/WritableMemChunk.java | 29 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 26 +-
.../modification/DropTableModProgress.java | 65 +
.../dataregion/snapshot/SnapshotLoader.java | 23 +-
.../dataregion/snapshot/SnapshotTaker.java | 2 +
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 4 +-
.../tsfile/timeindex/PlainDeviceTimeIndex.java | 4 +-
.../utils/TreeDiskUsageStatisticUtil.java | 2 +-
.../dataregion/wal/buffer/WALEntry.java | 6 +
.../dataregion/wal/buffer/WALEntryType.java | 4 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 6 +
.../dataregion/wal/node/IWALNode.java | 20 +
.../dataregion/wal/node/WALFakeNode.java | 6 +
.../storageengine/dataregion/wal/node/WALNode.java | 76 +-
.../wal/recover/file/TsFilePlanRedoer.java | 13 +-
.../file/UnsealedTsFileRecoverPerformer.java | 20 +-
.../db/storageengine/load/LoadConsensusCompat.java | 49 +
.../db/storageengine/load/LoadStagingDirs.java | 209 +++
.../db/storageengine/load/LoadTaskRetention.java | 185 ++
.../db/storageengine/load/LoadTsFileCleaner.java | 438 +++++
.../db/storageengine/load/LoadTsFileManager.java | 1234 +++++--------
.../db/storageengine/load/LoadTsFileProgress.java | 905 ++++++++++
.../db/storageengine/load/LoadTsFileSnapshot.java | 481 +++++
.../db/storageengine/load/TsFileWriterManager.java | 940 ++++++++++
.../load/memory/LoadTsFileAbstractMemoryBlock.java | 8 +
.../load/memory/LoadTsFileParserMemoryManager.java | 5 +-
.../load/memory/LoadTsFileSubMemoryBlock.java | 101 ++
.../load/metrics/LoadPointCountMetrics.java | 86 +
.../load/splitter/AlignedChunkData.java | 616 ++++---
.../splitter/BatchedAlignedValueChunkData.java | 178 +-
.../db/storageengine/load/splitter/ChunkData.java | 150 +-
.../load/splitter/ChunkPayloadRef.java | 205 +++
.../ChunkPayloadUnavailableException.java} | 19 +-
.../storageengine/load/splitter/DeletionData.java | 11 +
.../load/splitter/NonAlignedChunkData.java | 378 ++--
.../load/splitter/SerializedSizes.java | 78 +
.../db/storageengine/load/splitter/TsFileData.java | 28 +-
.../load/splitter/TsFileSplitter.java | 30 +-
.../iotdb/db/storageengine/load/util/LoadUtil.java | 9 +-
.../agent/SubscriptionBrokerAgent.java | 22 +-
.../agent/SubscriptionConsumerAgent.java | 82 +-
.../agent/SubscriptionRuntimeAgent.java | 2 +
.../subscription/agent/SubscriptionTopicAgent.java | 52 +
.../broker/ConsensusSubscriptionBroker.java | 32 +-
.../broker/SubscriptionPrefetchingQueue.java | 13 +-
.../consensus/ConsensusLogToTabletConverter.java | 41 +-
.../consensus/ConsensusPrefetchingQueue.java | 910 ++++++++--
.../ConsensusSubscriptionCommitManager.java | 169 +-
.../ConsensusSubscriptionSetupHandler.java | 340 +++-
.../ConsensusSubscriptionWalRetention.java | 163 ++
.../broker/consensus/ProgressWALIterator.java | 112 +-
.../columnfilter/TreeViewTabletProjector.java | 1 -
.../db/subscription/event/SubscriptionEvent.java | 84 +-
.../cache/CachedSubscriptionPollResponse.java | 1 +
.../event/cache/SubscriptionPollResponseCache.java | 8 +-
.../response/SubscriptionEventSingleResponse.java | 15 +-
.../response/SubscriptionEventTabletResponse.java | 8 +-
.../response/SubscriptionEventTsFileResponse.java | 8 +-
.../receiver/SubscriptionReceiverV1.java | 7 +-
.../java/org/apache/iotdb/db/tools/ImportWAL.java | 95 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 20 +-
.../org/apache/iotdb/db/utils/TypeServices.java | 67 +
.../write/TsFilePrecalculatedChunkWriter.java | 539 ++++++
.../LoadTsFileSplitPartitionMaxSizeConfigTest.java | 59 +
.../dataregion/IoTConsensusShutdownTest.java | 894 ++++++++++
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 62 +
.../task/connection/PipeEventCollectorTest.java | 4 +-
.../PipeProcessorSubtaskExecutionGuardTest.java | 10 +-
.../processor/PipeProcessorSubtaskTest.java | 87 +
.../processor/PipeProcessorSubtaskWorkerTest.java | 162 ++
.../pipe/event/PipeTabletInsertionEventTest.java | 36 +-
.../common/heartbeat/PipeHeartbeatEventTest.java | 92 +
.../PipeDataNodeCompletionOperatorTest.java | 248 +++
.../PipeDataNodeSinglePipeMetricsTest.java | 221 +++
.../pattern/CachedSchemaPatternMatcherTest.java | 1 +
.../memory/PipeMemoryManagerResizeTest.java | 332 +++-
.../resource/memory/PipeMemoryManagerTest.java | 30 +
.../airgap/IoTDBDataRegionAirGapSinkTest.java | 34 +-
.../db/pipe/source/PipeRealtimeExtractTest.java | 15 +-
.../realtime/PipeRealtimeDataRegionSourceTest.java | 25 +
.../assigner/PipeDataRegionAssignerTest.java | 88 +
.../PipeInsertionDataNodeListenerTest.java | 66 +
.../fragment/FragmentInstanceExecutionTest.java | 10 +-
.../source/DeviceBlackListConstructorTest.java | 120 ++
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 149 ++
.../plan/analyze/cache/PartitionCacheTest.java | 12 +
.../plan/planner/node/load/LoadTsFileNodeTest.java | 4 +-
.../node/load/LoadTsFileConsensusNodeTest.java | 277 +++
.../node/write/RelationalDeleteDataNodeTest.java | 22 +
.../plan/relational/analyzer/AnalyzerTest.java | 9 +
.../analyzer/EvaluateEmptyIntersectTest.java | 25 +-
.../analyzer/RemoveEmptyExceptBranchesTest.java | 82 +-
.../relational/analyzer/UnionOptimizeTest.java | 28 +-
...mentTest.java => CreateViewPrefixPathTest.java} | 29 +-
.../relational/sql/parser/ShowPipeMemoryTest.java | 63 +
.../scheduler/load/DataPartitionRouterTest.java | 171 ++
.../scheduler/load/LoadConsensusSubmitterTest.java | 249 +++
.../load/LoadTsFileDispatcherImplTest.java | 4 +-
.../scheduler/load/LoadTsFileSchedulerTest.java | 148 +-
.../TwoPhaseConsensusLoadStrategyAbortTest.java | 469 +++++
.../attribute/DeviceAttributeStoreTest.java | 129 ++
.../mtree/impl/mem/MTreeBelowSGMemoryImplTest.java | 129 ++
.../storageengine/dataregion/DataRegionTest.java | 314 +++-
.../compaction/AbstractCompactionTest.java | 121 +-
.../CompactionDataTypeAlterTableTest.java | 37 +-
.../InnerSeqCompactionWithFastPerformerTest.java | 3 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 7 +-
.../AbstractTableModelCompactionTest.java | 84 +
.../tablemodel/CompactionWithAllNullRowsTest.java | 3 +-
.../TableModelCompactionWithTTLTest.java | 11 +-
.../TableModelFastCompactionPerformerTest.java | 61 +-
...TableModelReadChunkCompactionPerformerTest.java | 155 +-
...TableModelReadPointCompactionPerformerTest.java | 61 +-
.../compaction/utils/CompactionUtilsTest.java | 11 +-
...ignedBitmapMemoryAccountingPerformanceTest.java | 7 +-
.../memtable/AlignedWritableMemChunkTest.java | 11 +-
.../memtable/MemChunkDeserializeTest.java | 12 +-
.../dataregion/memtable/MemTableFlushTaskTest.java | 28 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 27 +-
.../dataregion/memtable/TsFileProcessorTest.java | 221 +++
.../memtable/WritableMemChunkRegionScanTest.java | 9 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 52 +
.../storageengine/load/LoadTsFileCleanerTest.java | 326 ++++
.../load/LoadTsFileManagerDeletionTest.java | 445 +++++
.../load/LoadTsFileManagerSplitCoverageTest.java | 1839 ++++++++++++++++++++
.../storageengine/load/LoadTsFileManagerTest.java | 1150 ++++++++++++
.../storageengine/load/LoadTsFileProgressTest.java | 192 ++
.../storageengine/load/LoadTsFileResumeTest.java | 378 ++++
.../storageengine/load/LoadTsFileSnapshotTest.java | 544 ++++++
.../load/memory/LoadTsFileMemoryManagerTest.java | 2 +-
.../load/memory/LoadTsFileSubMemoryBlockTest.java | 113 ++
.../load/splitter/ChunkDataDirectWriteTest.java | 675 ++++++-
.../load/splitter/SerializedSizesTest.java | 70 +
.../db/storageengine/load/util/LoadUtilTest.java | 19 +
.../agent/SubscriptionTopicAgentTest.java | 116 ++
...riptionPrefetchingQueueRecycleIntervalTest.java | 160 ++
.../ConsensusLogToTabletConverterTest.java | 85 +
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 171 +-
.../ConsensusPrefetchingQueueDeliveryTest.java | 772 ++++++++
...onsensusPrefetchingQueueInitializationTest.java | 254 +++
.../ConsensusPrefetchingQueueSeekTest.java | 3 +-
.../consensus/ConsensusPrefetchingQueueTest.java | 505 +++++-
...nsensusPrefetchingQueueWalBackpressureTest.java | 373 +++-
...onsensusPrefetchingQueueWriterOrderingTest.java | 37 +
.../ConsensusSubscriptionCommitStateTest.java | 55 +
.../ConsensusSubscriptionSetupHandlerTest.java | 47 +
.../ConsensusSubscriptionWalRetentionTest.java | 102 ++
.../broker/consensus/ProgressWALIteratorTest.java | 158 ++
.../org/apache/iotdb/db/tools/ImportWALTest.java | 53 +-
.../conf/iotdb-system.properties.template | 19 +
.../org/apache/iotdb/commons/auth/entity/Role.java | 2 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 2 +-
.../commons/client/AbstractConfigNodeClient.java | 18 +-
.../client/property/ClientPoolProperty.java | 5 +-
.../consensus/index/impl/StateProgressIndex.java | 5 +-
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 2 +-
.../iotdb/commons/model/ModelHyperparameter.java | 2 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 4 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 2 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 4 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 46 +-
.../pipe/agent/task/meta/PipeStaticMeta.java | 33 +
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 17 +-
.../task/progress/PipeEventCommitManager.java | 15 +
.../iotdb/commons/pipe/event/EnrichedEvent.java | 14 +
.../commons/pipe/event/ProgressReportEvent.java | 5 +
.../IoTConsensusV2TransferFileSealWithModReq.java | 10 +-
.../thrift/request/PipeTransferFileSealReqV2.java | 8 +-
.../thrift/request/PipeTransferHandshakeV2Req.java | 4 +-
.../commons/queryengine/common/SessionInfo.java | 23 +-
.../plan/planner/plan/node/PlanNodeType.java | 1 +
.../planner/rowpattern/LogicalIndexPointer.java | 4 +-
.../plan/relational/sql/ast/InListExpression.java | 2 +-
.../iotdb/commons/request/IConsensusRequest.java | 13 +
.../schema/column/ColumnHeaderConstant.java | 19 +
.../multichildren/AbstractMultiChildrenFilter.java | 2 +-
.../schema/filter/impl/values/InFilter.java | 4 +-
.../commons/schema/table/InformationSchema.java | 63 +
.../multi/FunctionViewExpression.java | 4 +-
.../iotdb/commons/service/metric/enums/Metric.java | 6 +
.../meta/consumer/CommitProgressKeeper.java | 69 +-
.../meta/consumer/ConsumerGroupMeta.java | 37 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 2 +-
.../commons/utils/BasicStructureSerDeUtil.java | 15 +-
.../AbstractConfigNodeClientConnectionTest.java | 340 ++++
.../client/AbstractConfigNodeClientTest.java | 312 ++++
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 74 +
.../consumer/ConsumerGroupDeSerTest.java | 39 +
.../meta/consumer/CommitProgressKeeperTest.java | 45 +
.../iotdb/rpc/ClientPoolIdleEvictionTest.java | 326 ++++
.../db/relational/grammar/sql/RelationalSql.g4 | 8 +-
.../src/main/thrift/confignode.thrift | 17 +
.../src/main/thrift/datanode.thrift | 19 +
.../apache/iotdb/library/dprofile/UDTFSegment.java | 2 +-
.../iotdb/library/match/PatternExecutor.java | 6 +-
pom.xml | 2 +-
scripts/sbin/windows/stop-datanode.bat | 5 +-
479 files changed, 36839 insertions(+), 4838 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileClusterIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBShowPipeMemoryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/utils/IoTDBTestUtilsIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDropTableModProgressIT.java
create mode 100644 iotdb-client/client-py/tests/unit/test_session_query_ids.py
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/BrokenSessionConnectionTest.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{SubmitTestConnectionTaskRPCHandler.java
=> GetDropTableModProgressRPCHandler.java} (57%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/client/async/CnToDnInternalServiceAsyncRequestManagerTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/common/request/IndexedConsensusRequestTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeCompletionOperator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/{PipeMemoryBlockType.java
=> PipeMemoryBlockCategory.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadPieceConsensusRequest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadTsFileConsensusNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadTsFileConsensusOp.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/ChunkOffsetCalculator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionBatchFetcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionResolver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionRouter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadConsensusSubmitter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadFallbackHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LocalLoadStrategy.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/MemoryBoundedBuffer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/PieceDispatcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TsFileLoadStrategy.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TsFileSplitConsumer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TwoPhaseConsensusLoadStrategy.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{template/ShowSchemaTemplateStatement.java
=> pipe/ShowPipeMemoryStatement.java} (56%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/DropTableModProgress.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadConsensusCompat.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadStagingDirs.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTaskRetention.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileCleaner.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileProgress.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileSnapshot.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/TsFileWriterManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileSubMemoryBlock.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/metrics/LoadPointCountMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/ChunkPayloadRef.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/sql/StatementAnalyzeException.java
=> storageengine/load/splitter/ChunkPayloadUnavailableException.java} (58%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/SerializedSizes.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionWalRetention.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/tsfile/write/TsFilePrecalculatedChunkWriter.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/LoadTsFileSplitPartitionMaxSizeConfigTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/consensus/statemachine/dataregion/IoTConsensusShutdownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/heartbeat/PipeHeartbeatEventTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeCompletionOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeSinglePipeMetricsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/PipeDataRegionAssignerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/listener/PipeInsertionDataNodeListenerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DeviceBlackListConstructorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadTsFileConsensusNodeTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/{TopicStatementTest.java
=> CreateViewPrefixPathTest.java} (58%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/ShowPipeMemoryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionRouterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadConsensusSubmitterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TwoPhaseConsensusLoadStrategyAbortTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tablemodel/AbstractTableModelCompactionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileCleanerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManagerDeletionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManagerSplitCoverageTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileProgressTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileResumeTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileSnapshotTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileSubMemoryBlockTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/splitter/SerializedSizesTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueueRecycleIntervalTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueDeliveryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueInitializationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionWalRetentionTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/AbstractConfigNodeClientConnectionTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/AbstractConfigNodeClientTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/rpc/ClientPoolIdleEvictionTest.java
