This is an automated email from the ASF dual-hosted git repository.
Wei-hao-Li pushed a change to branch fixLimit0
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from aca66c88e4d fix
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 7764fc477f9 Merge branch 'master' of github.com:apache/iotdb into
fixLimit0
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 c5ff6fae28d Merge branch 'master' of github.com:apache/iotdb into
fixLimit0
add f2af7813181 fix
No new revisions were added by this update.
Summary of changes:
.../query/view/recent/IoTDBTableViewQueryIT.java | 2 +-
.../relational/it/schema/IoTDBTableDDLHAIT.java | 37 ++-
.../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 ++++++++++++++++++
.../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 +-
.../request/write/auth/AuthorTreePlan.java | 4 +-
.../pipe/payload/PipeDeactivateTemplatePlan.java | 4 +-
.../pipe/task/OperateMultiplePipesPlanV2.java | 2 +-
.../topic/AlterMultipleTopicsPlan.java | 2 +-
.../impl/schema/DeactivateTemplateProcedure.java | 3 +-
.../impl/sync/AuthOperationProcedure.java | 2 +-
.../subscription/SubscriptionQueueRegistry.java | 5 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 12 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 12 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 39 +++-
.../query/TsFileInsertionEventQueryParser.java | 3 +-
...ileInsertionEventQueryParserTabletIterator.java | 2 +-
.../scan/TsFileInsertionEventScanParser.java | 10 +-
...ileInsertionEventTableParserTabletIterator.java | 7 +-
.../tsfile/parser/util/ModsOperationUtil.java | 24 +-
.../payload/FetchCombineResultRequest.java | 2 +-
.../builder/PipeTableModelTsFileBuilderV2.java | 3 +-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 3 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 16 +-
.../matcher/CachedSchemaPatternMatcher.java | 25 +-
.../db/queryengine/common/TimeseriesContext.java | 4 +-
.../fragment/FragmentInstanceContext.java | 4 +-
.../fragment/FragmentInstanceFailureInfo.java | 4 +-
.../execution/fragment/QueryContext.java | 12 +-
.../operator/process/TransformOperator.java | 2 +-
.../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 +-
.../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 +-
.../TableDeviceAttributeCommitUpdateNode.java | 4 +-
.../visitor/SchemaRegionPlanDeserializer.java | 18 +-
.../schemaregion/utils/ResourceByPathUtils.java | 5 +-
.../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 | 60 +++--
.../memtable/AlignedWritableMemChunkGroup.java | 37 ++-
.../dataregion/memtable/IMemTable.java | 8 +-
.../dataregion/memtable/IWritableMemChunk.java | 14 +-
.../memtable/IWritableMemChunkGroup.java | 12 +-
.../dataregion/memtable/TsFileProcessor.java | 25 +-
.../dataregion/memtable/WritableMemChunk.java | 29 ++-
.../dataregion/memtable/WritableMemChunkGroup.java | 26 ++-
.../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/splitter/AlignedChunkData.java | 4 +-
.../consensus/ConsensusLogToTabletConverter.java | 13 +-
.../consensus/ConsensusPrefetchingQueue.java | 39 +++-
.../ConsensusSubscriptionCommitManager.java | 93 +++++---
.../columnfilter/TreeViewTabletProjector.java | 1 -
.../java/org/apache/iotdb/db/tools/ImportWAL.java | 95 ++++++--
.../apache/iotdb/db/utils/ModificationUtils.java | 20 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 36 +--
.../pattern/CachedSchemaPatternMatcherTest.java | 1 +
.../db/pipe/source/PipeRealtimeExtractTest.java | 15 +-
.../fragment/FragmentInstanceExecutionTest.java | 10 +-
.../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 | 11 +-
.../memtable/MemChunkDeserializeTest.java | 12 +-
.../dataregion/memtable/MemTableFlushTaskTest.java | 28 +--
.../dataregion/memtable/PrimitiveMemTableTest.java | 27 ++-
.../memtable/WritableMemChunkRegionScanTest.java | 9 +-
.../ConsensusLogToTabletConverterTest.java | 60 +++++
...onsensusPrefetchingQueueInitializationTest.java | 251 +++++++++++++++++++++
...nsensusPrefetchingQueueWalBackpressureTest.java | 182 ++++++++++++++-
.../ConsensusSubscriptionCommitStateTest.java | 20 ++
.../org/apache/iotdb/db/tools/ImportWALTest.java | 53 ++++-
.../org/apache/iotdb/commons/auth/entity/Role.java | 2 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 2 +-
.../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 +-
.../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 +-
.../multichildren/AbstractMultiChildrenFilter.java | 2 +-
.../schema/filter/impl/values/InFilter.java | 4 +-
.../multi/FunctionViewExpression.java | 4 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 2 +-
.../commons/utils/BasicStructureSerDeUtil.java | 15 +-
.../apache/iotdb/library/dprofile/UDTFSegment.java | 2 +-
.../iotdb/library/match/PatternExecutor.java | 6 +-
pom.xml | 2 +-
148 files changed, 1868 insertions(+), 913 deletions(-)
create mode 100644
iotdb-client/session/src/test/java/org/apache/iotdb/session/BrokenSessionConnectionTest.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/subscription/broker/consensus/ConsensusPrefetchingQueueInitializationTest.java
