This is an automated email from the ASF dual-hosted git repository.
JackieTien97 pushed a change to branch rc/2.0.10
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7e488ffcaca modify the antlr syntax to adapt the calc-point project
(#17783)
new 17d4baf339a Feature/iotconsensus snap multi dir (#16811)
new 4055beb798f fix: supply the key word in antlr module (#17789)
new 7128b9fc4c6 Fix repeated RPC dispatch reusing a released
FragmentInstanceContext (NPE) (#17794)
new 6bc95b193cb Pipe: account page decode memory in scan parser (#17807)
new 7a4cfdf7577 Fix pipe tsfile receiver database handling (#17815)
new 8da40c6bc97 [AINode] Remove Chronos2 DataLoader pin_memory option
(#17822)
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../iotdb/ainode/it/AINodeSharedClusterIT.java | 83 ++++++++
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../request_scheduler/basic_request_scheduler.py | 19 +-
.../core/model/chronos2/pipeline_chronos2.py | 1 -
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../iotdb/consensus/config/ConsensusConfig.java | 15 ++
.../apache/iotdb/consensus/iot/IoTConsensus.java | 32 ++-
.../consensus/iot/IoTConsensusServerImpl.java | 96 +++++++--
.../apache/iotdb/consensus/iot/ReplicateTest.java | 27 +++
.../apache/iotdb/consensus/iot/StabilityTest.java | 8 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 13 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +
.../db/consensus/DataRegionConsensusImpl.java | 2 +
.../scan/AlignedSinglePageWholeChunkReader.java | 55 +++++-
.../parser/scan/MemoryControlledChunkReader.java | 76 ++++++++
.../parser/scan/SinglePageWholeChunkReader.java | 193 +++++++++++++++++-
.../scan/TsFileInsertionEventScanParser.java | 53 +++--
.../iotconsensusv2/IoTConsensusV2Receiver.java | 6 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 68 +++++--
.../visitor/PipeStatementExceptionVisitor.java | 7 +
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 6 +-
.../execution/executor/RegionReadExecutor.java | 23 ++-
.../fragment/FragmentInstanceManager.java | 79 +++++---
.../scheduler/FragmentInstanceDispatcherImpl.java | 15 ++
.../plan/statement/crud/LoadTsFileStatement.java | 25 +++
.../db/storageengine/dataregion/DataRegion.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 2 +-
.../impl/SizeTieredCompactionSelector.java | 2 +-
.../dataregion/snapshot/SnapshotLoader.java | 106 +++++-----
.../tsfile/generator/TsFileNameGenerator.java | 4 +-
.../allocation/AbstractNodeAllocationStrategy.java | 6 +-
.../db/storageengine/load/LoadTsFileManager.java | 6 +-
.../storageengine/load/disk/ILoadDiskSelector.java | 2 +-
.../InheritSystemMultiDisksStrategySelector.java | 2 +-
.../db/storageengine/load/disk/MinIOSelector.java | 2 +-
.../iotdb/db/storageengine/load/util/LoadUtil.java | 6 +-
.../db/storageengine/rescon/disk/TierManager.java | 11 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 2 +-
.../strategy/DirectoryStrategyTest.java | 10 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 215 +++++++++++++++++++++
.../receiver/PipeStatementTsStatusVisitorTest.java | 14 ++
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 110 +++++++++++
.../execution/executor/RegionReadExecutorTest.java | 46 +++++
.../iotdb/db/storageengine/dataregion/TTLTest.java | 4 +-
.../BatchedCompactionWithTsFileSplitterTest.java | 16 +-
...actionWithReadPointPerformerValidationTest.java | 4 +-
.../utils/CompactionFileGeneratorUtils.java | 2 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 7 +-
.../dataregion/snapshot/IoTDBSnapshotTest.java | 115 +++++++++--
.../rescon/disk/FolderManagerTest.java | 5 +-
.../conf/iotdb-system.properties.template | 6 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 12 ++
.../apache/iotdb/commons/i18n/UtilMessages.java | 12 ++
.../apache/iotdb/commons}/disk/FolderManager.java | 53 +++--
.../commons}/disk/strategy/DirectoryStrategy.java | 12 +-
.../disk/strategy/DirectoryStrategyType.java | 2 +-
.../strategy/MaxDiskUsableSpaceFirstStrategy.java | 4 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 8 +-
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +-
.../commons}/disk/strategy/SequenceStrategy.java | 4 +-
.../exception/DiskSpaceInsufficientException.java | 4 +-
61 files changed, 1485 insertions(+), 247 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/MemoryControlledChunkReader.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiverTest.java
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/FolderManager.java
(72%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/DirectoryStrategy.java
(88%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/DirectoryStrategyType.java
(93%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/MaxDiskUsableSpaceFirstStrategy.java
(92%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/MinFolderOccupiedSpaceFirstStrategy.java
(87%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/RandomOnDiskUsableSpaceStrategy.java
(94%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon =>
node-commons/src/main/java/org/apache/iotdb/commons}/disk/strategy/SequenceStrategy.java
(95%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/DiskSpaceInsufficientException.java
(91%)
