This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch air-gap-udp-transport
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 045622d045d Merge origin/master into air-gap-udp-transport
add 932c1da25f7 Batch aligned memtable column expansion to reduce region
lock contention (#18816)
add 86b46e61a81 Fix stale fragment cleanup removing query memory
registrations (#18834)
add 45411925426 Temporarily skip IoTDBNodeStatusFailoverIT (#18839)
add 17b95c8360e Expand some plan types for use in the future (#18836)
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 4903676cbd2 Merge commit '1b290ae320c56ee7b2693564dd9cb98bdef80c74'
into codex/pr-17954-conflict
No new revisions were added by this update.
Summary of changes:
.../it/cluster/IoTDBNodeStatusFailoverIT.java | 21 +-
.../apache/iotdb/db/it/IoTDBShowPipeMemoryIT.java | 246 ++++++
.../iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java | 5 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 20 +
.../it/query/old/IoTDBSimpleQueryTableIT.java | 24 +
.../query/view/recent/IoTDBTableViewQueryIT.java | 2 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 69 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 13 +-
.../it/schema/IoTDBDropTableModProgressIT.java | 105 +++
.../relational/it/schema/IoTDBTableDDLHAIT.java | 37 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 71 ++
.../it/session/IoTDBSessionRelationalIT.java | 24 +-
.../org/apache/iotdb/pipe/api/event/Event.java | 18 +-
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 +-
.../java/org/apache/iotdb/session/Session.java | 14 +-
.../apache/iotdb/session/SessionConnection.java | 21 +-
.../apache/iotdb/session/util/SessionUtils.java | 2 +-
.../iotdb/session/BrokenSessionConnectionTest.java | 222 +++++
.../iotdb/rpc/subscription/config/TopicConfig.java | 8 +
.../rpc/subscription/config/TopicConstant.java | 3 +
.../rpc/subscription/config/TopicConfigTest.java | 12 +
.../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 | 6 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 6 +
.../client/async/CnToDnAsyncRequestType.java | 1 +
.../CnToDnInternalServiceAsyncRequestManager.java | 15 +-
.../rpc/DataNodeAsyncRequestRPCHandler.java | 9 +
...java => GetDropTableModProgressRPCHandler.java} | 37 +-
.../consensus/request/ConfigPhysicalPlanType.java | 2 +
.../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 | 109 ++-
.../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 | 125 +++
.../SubscriptionInfoTopicValidationTest.java | 44 +
.../impl/schema/table/DropTableProcedureTest.java | 333 +++++++
.../apache/iotdb/consensus/iot/IoTConsensus.java | 15 +-
.../consensus/iot/IoTConsensusServerImpl.java | 38 +-
.../subscription/SubscriptionQueueRegistry.java | 55 +-
.../SubscriptionQueueRegistryTest.java | 42 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 2 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 5 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 12 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 2 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 5 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 12 +-
.../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 +-
.../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 +
.../impl/DataNodeInternalRPCServiceImpl.java | 28 +-
.../db/queryengine/common/TimeseriesContext.java | 4 +-
.../fragment/FragmentInstanceContext.java | 4 +-
.../fragment/FragmentInstanceFailureInfo.java | 4 +-
.../execution/fragment/QueryContext.java | 12 +-
.../queryengine/execution/memory/MemoryPool.java | 5 +-
.../operator/process/TransformOperator.java | 2 +-
.../schema/source/DeviceBlackListConstructor.java | 14 +-
.../InformationSchemaContentSupplierFactory.java | 135 +++
.../iotdb/db/queryengine/plan/Coordinator.java | 23 +
.../analyze/cache/partition/PartitionCache.java | 42 +-
.../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 +
.../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 +-
.../planner/plan/node/write/InsertRowsNode.java | 5 +-
.../plan/node/write/RelationalInsertRowsNode.java | 5 +-
.../parameter/model/ModelInferenceDescriptor.java | 4 +-
.../relational/analyzer/StatementAnalyzer.java | 4 +-
.../TableDeviceAttributeCommitUpdateNode.java | 4 +-
.../DataNodeLocationSupplierFactory.java | 2 +
.../security/TreeAccessCheckVisitor.java | 10 +
.../plan/relational/sql/parser/AstBuilder.java | 12 +
.../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/storageengine/StorageEngine.java | 17 +-
.../db/storageengine/dataregion/DataRegion.java | 182 +++-
.../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 | 58 +-
.../memtable/AbstractWritableMemChunk.java | 9 +-
.../memtable/AlignedWritableMemChunk.java | 99 ++-
.../memtable/AlignedWritableMemChunkGroup.java | 37 +-
.../dataregion/memtable/IMemTable.java | 8 +-
.../dataregion/memtable/IWritableMemChunk.java | 14 +-
.../memtable/IWritableMemChunkGroup.java | 12 +-
.../dataregion/memtable/TsFileProcessor.java | 69 +-
.../dataregion/memtable/WritableMemChunk.java | 29 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 26 +-
.../modification/DropTableModProgress.java | 65 ++
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 4 +-
.../tsfile/timeindex/PlainDeviceTimeIndex.java | 4 +-
.../utils/TreeDiskUsageStatisticUtil.java | 2 +-
.../wal/recover/file/TsFilePlanRedoer.java | 9 +-
.../file/UnsealedTsFileRecoverPerformer.java | 20 +-
.../load/memory/LoadTsFileParserMemoryManager.java | 5 +-
.../load/splitter/AlignedChunkData.java | 4 +-
.../agent/SubscriptionBrokerAgent.java | 12 +-
.../agent/SubscriptionConsumerAgent.java | 42 +
.../agent/SubscriptionRuntimeAgent.java | 2 +
.../subscription/agent/SubscriptionTopicAgent.java | 5 +
.../broker/ConsensusSubscriptionBroker.java | 24 +-
.../consensus/ConsensusLogToTabletConverter.java | 13 +-
.../consensus/ConsensusPrefetchingQueue.java | 377 +++++---
.../ConsensusSubscriptionCommitManager.java | 169 +++-
.../ConsensusSubscriptionSetupHandler.java | 308 ++++++-
.../ConsensusSubscriptionWalRetention.java | 163 ++++
.../broker/consensus/ProgressWALIterator.java | 78 +-
.../columnfilter/TreeViewTabletProjector.java | 1 -
.../event/cache/SubscriptionPollResponseCache.java | 8 +-
.../response/SubscriptionEventTabletResponse.java | 8 +-
.../response/SubscriptionEventTsFileResponse.java | 8 +-
.../java/org/apache/iotdb/db/tools/ImportWAL.java | 95 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 20 +-
.../db/utils/datastructure/AlignedTVList.java | 34 +-
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 62 ++
.../task/connection/PipeEventCollectorTest.java | 4 +-
.../PipeProcessorSubtaskExecutionGuardTest.java | 10 +-
.../processor/PipeProcessorSubtaskTest.java | 87 ++
.../processor/PipeProcessorSubtaskWorkerTest.java | 154 ++++
.../pipe/event/PipeTabletInsertionEventTest.java | 36 +-
.../common/heartbeat/PipeHeartbeatEventTest.java | 92 ++
.../PipeDataNodeCompletionOperatorTest.java | 248 ++++++
.../PipeDataNodeSinglePipeMetricsTest.java | 221 +++++
.../pattern/CachedSchemaPatternMatcherTest.java | 1 +
.../memory/PipeMemoryManagerResizeTest.java | 321 ++++++-
.../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 +-
.../execution/memory/MemoryPoolTest.java | 128 +++
.../source/DeviceBlackListConstructorTest.java | 120 +++
.../node/write/RelationalDeleteDataNodeTest.java | 22 +
.../plan/relational/analyzer/AnalyzerTest.java | 9 +
.../analyzer/EvaluateEmptyIntersectTest.java | 25 +-
.../analyzer/RemoveEmptyExceptBranchesTest.java | 82 +-
.../relational/analyzer/UnionOptimizeTest.java | 28 +-
.../relational/sql/parser/ShowPipeMemoryTest.java | 63 ++
.../attribute/DeviceAttributeStoreTest.java | 129 +++
.../mtree/impl/mem/MTreeBelowSGMemoryImplTest.java | 129 +++
.../storageengine/dataregion/DataRegionTest.java | 295 ++++++-
.../compaction/AbstractCompactionTest.java | 121 +--
.../CompactionDataTypeAlterTableTest.java | 37 +-
.../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 | 216 +++++
.../memtable/MemChunkDeserializeTest.java | 12 +-
.../dataregion/memtable/MemTableFlushTaskTest.java | 28 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 27 +-
.../memtable/WritableMemChunkRegionScanTest.java | 9 +-
.../load/memory/LoadTsFileMemoryManagerTest.java | 2 +-
.../ConsensusLogToTabletConverterTest.java | 60 ++
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 170 +++-
...onsensusPrefetchingQueueInitializationTest.java | 254 ++++++
.../ConsensusPrefetchingQueueSeekTest.java | 3 +-
.../consensus/ConsensusPrefetchingQueueTest.java | 161 ++--
...nsensusPrefetchingQueueWalBackpressureTest.java | 322 ++++++-
.../ConsensusSubscriptionCommitStateTest.java | 55 ++
.../ConsensusSubscriptionSetupHandlerTest.java | 47 +
.../ConsensusSubscriptionWalRetentionTest.java | 102 +++
.../broker/consensus/ProgressWALIteratorTest.java | 110 +++
.../org/apache/iotdb/db/tools/ImportWALTest.java | 53 +-
.../db/utils/datastructure/AlignedTVListTest.java | 66 ++
.../org/apache/iotdb/commons/auth/entity/Role.java | 2 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 2 +-
.../commons/client/AbstractConfigNodeClient.java | 6 +
.../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 +-
.../planner/rowpattern/LogicalIndexPointer.java | 4 +-
.../plan/relational/sql/ast/InListExpression.java | 2 +-
.../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 | 15 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 2 +-
.../commons/utils/BasicStructureSerDeUtil.java | 15 +-
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 74 ++
.../meta/consumer/CommitProgressKeeperTest.java | 19 +
.../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 +-
335 files changed, 12493 insertions(+), 1825 deletions(-)
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/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/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%)
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/subscription/broker/consensus/ConsensusSubscriptionWalRetention.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/relational/sql/parser/ShowPipeMemoryTest.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/dataregion/memtable/AlignedWritableMemChunkTest.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/rpc/ClientPoolIdleEvictionTest.java
