This is an automated email from the ASF dual-hosted git repository. jt2594838 pushed a commit to branch table_insert_tablets in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit afbea6c558d18022f8d48289776a8e4e51e54dc9 Merge: e7eefcdc1c5 f3e161218d6 Author: Tian Jiang <[email protected]> AuthorDate: Thu Jul 9 11:35:29 2026 +0800 Merge branch 'master' into table_insert_tablets .../it/database/IoTDBDatabaseRegionControlIT.java | 111 ++++ .../commit/IoTDBMigrateMultiRegionForIoTV1IT.java | 66 +++ ...TDBRegionMigrateWithDeletionMultiDataDirIT.java | 14 +- ...gionMigrateWithDeletionMultiDataDirTableIT.java | 14 +- .../RegionMigrateFileAssertions.java | 2 +- .../IoTDBRegionMigrateNormalITForIoTV2BatchIT.java | 34 ++ .../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 10 +- .../IoTDBPipeReceiverAutoCreateDisabledIT.java | 37 ++ .../relational/it/db/it/IoTDBDeletionTableIT.java | 565 ++++++++++++++++++++- .../it/db/it/IoTDBLoadConfigurationTableIT.java | 110 ++++ .../schema/IoTDBDatabaseMaxRegionGroupNumIT.java | 73 +++ .../java/org/apache/iotdb/jdbc/StringUtils.java | 21 +- .../org/apache/iotdb/jdbc/StringUtilsTest.java | 74 +++ .../iotdb/confignode/i18n/ManagerMessages.java | 3 + .../iotdb/confignode/i18n/ProcedureMessages.java | 2 + .../iotdb/confignode/i18n/ManagerMessages.java | 3 + .../iotdb/confignode/i18n/ProcedureMessages.java | 2 + .../load/cache/region/RegionGroupCache.java | 8 +- .../pipe/coordinator/task/PipeTaskCoordinator.java | 30 +- .../receiver/protocol/IoTDBConfigNodeReceiver.java | 56 +- .../pipe/source/IoTDBConfigRegionSource.java | 21 +- .../manager/schema/ClusterSchemaManager.java | 36 +- .../procedure/impl/StateMachineProcedure.java | 13 +- .../PipeConfigTreePrivilegeParseVisitorTest.java | 43 ++ .../confignode/procedure/STMProcedureTest.java | 70 +++ .../pipe/AbstractOperatePipeProcedureV2Test.java | 3 +- .../consensus/iot/IoTConsensusServerImpl.java | 13 +- .../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 4 +- .../apache/iotdb/db/i18n/DataNodePipeMessages.java | 18 +- .../iotdb/db/i18n/DataNodeQueryMessages.java | 70 ++- .../iotdb/db/i18n/StorageEngineMessages.java | 2 + .../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 2 +- .../apache/iotdb/db/i18n/DataNodePipeMessages.java | 18 +- .../iotdb/db/i18n/DataNodeQueryMessages.java | 58 ++- .../iotdb/db/i18n/StorageEngineMessages.java | 2 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 38 +- .../DirectBufferMemoryAllocationException.java} | 24 +- .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 455 +++-------------- .../task/builder/PipeDataNodeTaskBuilder.java | 36 ++ .../agent/task/connection/PipeEventCollector.java | 15 +- .../agent/task/stage/PipeTaskProcessorStage.java | 5 +- .../subtask/processor/PipeProcessorSubtask.java | 2 + .../common/tsfile/PipeTsFileInsertionEvent.java | 144 ++++-- .../tsfile/parser/TsFileInsertionEventParser.java | 12 +- .../query/TsFileInsertionEventQueryParser.java | 1 + .../scan/TsFileInsertionEventScanParser.java | 14 +- .../table/TsFileInsertionEventTableParser.java | 22 +- .../processor/aggregate/AggregateProcessor.java | 3 + .../downsampling/DownSamplingProcessor.java | 3 + .../receiver/TwoStageAggregateReceiver.java | 10 + .../exchange/sender/TwoStageAggregateSender.java | 75 ++- .../twostage/plugin/TwoStageCountProcessor.java | 9 +- .../protocol/thrift/IoTDBDataNodeReceiver.java | 178 ++++++- .../db/pipe/resource/memory/PipeMemoryManager.java | 95 +++- .../evolvable/batch/PipeTabletEventBatch.java | 69 ++- .../evolvable/batch/PipeTabletEventPlainBatch.java | 61 ++- .../batch/PipeTabletEventTsFileBatch.java | 30 +- .../protocol/airgap/IoTDBDataRegionAirGapSink.java | 18 +- .../iotconsensusv2/IoTConsensusV2SyncSink.java | 20 +- .../IoTConsensusV2TsFileInsertionEventHandler.java | 34 +- .../IoTConsensusV2TransferBatchReqBuilder.java | 109 ++-- .../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 17 +- .../async/handler/PipeTransferTsFileHandler.java | 42 +- .../thrift/sync/IoTDBDataRegionSyncSink.java | 136 +++++ ...istoricalDataRegionTsFileAndDeletionSource.java | 31 +- .../realtime/PipeRealtimeDataRegionSource.java | 17 +- .../schemaregion/IoTDBSchemaRegionSource.java | 4 +- .../PipePlanTablePrivilegeParseVisitor.java | 17 + .../protocol/thrift/impl/ClientRPCServiceImpl.java | 42 +- .../impl/DataNodeInternalRPCServiceImpl.java | 4 +- .../db/queryengine/common/MPPQueryContext.java | 286 ++++++++++- .../common/schematree/ClusterSchemaTree.java | 8 + .../db/queryengine/plan/analyze/AnalyzeUtils.java | 436 ++++++++++++++-- .../queryengine/plan/analyze/AnalyzeVisitor.java | 8 + .../queryengine/plan/analyze/ExpressionUtils.java | 2 + .../analyze/schema/ClusterSchemaFetchExecutor.java | 9 + .../config/executor/ClusterConfigTaskExecutor.java | 25 +- .../relational/analyzer/StatementAnalyzer.java | 2 +- .../read_tsfile/ExternalTsFileQueryResource.java | 9 +- .../tvf/read_tsfile/ReadTsFileTableFunction.java | 60 ++- .../plan/relational/planner/RelationPlanner.java | 5 +- .../plan/relational/sql/ast/DeleteDevice.java | 5 +- .../db/schemaengine/table/DataNodeTableCache.java | 2 +- .../iotdb/db/storageengine/StorageEngine.java | 18 +- .../db/storageengine/dataregion/DataRegion.java | 26 +- .../compaction/execute/utils/CompactionUtils.java | 2 +- .../memtable/AlignedWritableMemChunk.java | 92 +++- .../dataregion/modification/DeletionPredicate.java | 46 +- .../modification/TableDeletionEntry.java | 6 +- .../{IDPredicate.java => TagPredicate.java} | 261 ++++++++-- .../dataregion/tsfile/TsFileResource.java | 41 +- .../file/UnsealedTsFileRecoverPerformer.java | 2 +- .../iotdb/db/metadata/path/PatternTreeMapTest.java | 2 +- .../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 88 ---- .../db/pipe/consensus/DeletionRecoverTest.java | 2 +- .../db/pipe/consensus/DeletionResourceTest.java | 2 +- .../pipe/event/TsFileInsertionEventParserTest.java | 154 ++++++ .../iotdb/db/pipe/sink/PipeReceiverTest.java | 70 ++- .../PipeTabletEventPlainBatchPerformanceTest.java | 137 +++++ .../PipePlanTablePatternParseVisitorTest.java | 57 ++- .../db/pipe/source/PipeRealtimeExtractTest.java | 73 +++ .../db/queryengine/common/MPPQueryContextTest.java | 125 +++++ .../queryengine/plan/analyze/AnalyzeUtilsTest.java | 6 +- .../node/write/RelationalDeleteDataNodeTest.java | 8 +- .../ExternalTsFileQueryResourceTest.java | 7 +- .../schemaengine/table/DataNodeTableCacheTest.java | 20 + .../iotdb/db/storageengine/StorageEngineTest.java | 45 ++ .../storageengine/dataregion/DataRegionTest.java | 2 +- .../tablemodel/CompactionWithAllNullRowsTest.java | 12 +- .../modification/ModificationFileTest.java | 27 +- .../modification/TableDeletionEntryTest.java | 48 +- .../dataregion/tsfile/TsFileResourceTest.java | 19 +- .../conf/iotdb-system.properties.template | 2 +- .../apache/iotdb/commons/i18n/PipeMessages.java | 2 + .../apache/iotdb/commons/i18n/UtilMessages.java | 2 + .../apache/iotdb/commons/i18n/PipeMessages.java | 2 + .../apache/iotdb/commons/i18n/UtilMessages.java | 2 + .../apache/iotdb/commons/disk/FolderManager.java | 30 +- .../MinFolderOccupiedSpaceFirstStrategy.java | 3 +- .../pipe/config/constant/PipeSourceConstant.java | 41 ++ .../env/PipeTaskProcessorRuntimeEnvironment.java | 23 + .../datastructure/visibility/VisibilityUtils.java | 9 +- .../commons/pipe/receiver/IoTDBFileReceiver.java | 103 +++- .../thrift/common/PipeTransferSliceReqHandler.java | 37 ++ .../thrift/request/PipeTransferCompressedReq.java | 21 + .../iotdb/commons/pipe/source/IoTDBSource.java | 18 +- .../apache/iotdb/commons/utils/JVMCommonUtils.java | 30 +- ...FolderOccupiedSpaceFirstStrategyRealFsTest.java | 61 +++ .../visibility/VisibilityUtilsTest.java | 24 + .../pipe/receiver/IoTDBFileReceiverTest.java | 184 ++++++- .../common/PipeTransferSliceReqBuilderTest.java | 52 ++ .../request/PipeTransferCompressedReqTest.java | 37 ++ .../iotdb/commons/utils/JVMCommonUtilsTest.java | 48 ++ 133 files changed, 5226 insertions(+), 1160 deletions(-)
