This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch fix_flush_stuck
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from fd01acf76e1 Fix flush command stuck
add 3bd8af06571 bump ratis to 3.1.2 (#14044)
add 46af90ca211 modify stop node scripts (#14047)
add 12bc4f89d96 Fix exec remove-datanode.sh failed in jdk17 (#14036)
add 10b1220537d IoTConsensusV2: Fix Create DataRegion Failed. #14050
add e437ef3d056 [remove datanode] Log the node information when submitting
RegionMigrateProcedure (#14051)
add 7e08e68a0d4 IoTConsensusV2 X [Region Migration] Each component uses
an independent ClientManager && Filter out the consensus pipe when judging
resource release #14052
add 5db013aae64 Pipe: Fix the null pointer caused by uninitialized
TabletInsertionEventParser LocalDate and Binary arrays (#14058)
add de9645dde1b Pipe: avoid supply event with failed tsfile resource pin &
apply double-checked locking for exists-and-mkdirs operation (#13998)
add d723880394b Modify default heap dump path of datanode (#14060)
add 70006df9bbc When the thread is interrupted while retrying a
connection, the loop will exit early. (#14062)
add 57c668ca516 Pipe: atomically publish segment lock to avoid
uninitialized volatile variable (#14064)
add e1cc2294e7d Add or modify encryption related codes (#13364)
add c07bb3f118b Merge branch 'master' of github.com:apache/iotdb into
fix_flush_stuck
add 153ac1ceef2 fix ArrayIndexOutOfBoundsException
add ce0ed5eb425 refactor flush manager
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppCommonConfig.java | 18 ++
.../env/cluster/config/MppSharedCommonConfig.java | 21 +++
.../it/env/remote/config/RemoteCommonConfig.java | 15 ++
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
...emoIT.java => IoTDBEncryptionValueQueryIT.java} | 11 +-
.../db/it/query/IoTDBLoadEncryptedTsFileIT.java | 204 +++++++++++++++++++++
.../IoTDBLoadPlainTsFileIT.java} | 104 ++++++-----
.../apache/iotdb/session/SessionConnection.java | 8 +-
.../assembly/resources/sbin/stop-confignode.bat | 8 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 5 +
.../load/cache/node/DataNodeHeartbeatCache.java | 9 +
.../procedure/env/RemoveDataNodeHandler.java | 28 ++-
.../impl/node/RemoveDataNodesProcedure.java | 8 +-
.../procedure/impl/region/RegionMigrationPlan.java | 12 ++
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 13 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 1 +
.../pipe/consensuspipe/ConsensusPipeManager.java | 6 +-
.../src/assembly/resources/conf/datanode-env.sh | 44 ++++-
.../assembly/resources/sbin/remove-datanode.bat | 4 +-
.../src/assembly/resources/sbin/remove-datanode.sh | 2 +-
.../src/assembly/resources/sbin/stop-datanode.bat | 8 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 5 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 18 ++
.../pipeconsensus/PipeConsensusAsyncConnector.java | 2 +-
.../pipeconsensus/PipeConsensusSyncConnector.java | 2 +-
.../tablet/parser/TabletInsertionEventParser.java | 8 +-
.../scan/AlignedSinglePageWholeChunkReader.java | 11 +-
.../parser/scan/SinglePageWholeChunkReader.java | 50 ++++-
...oricalDataRegionTsFileAndDeletionExtractor.java | 7 +-
.../tsfile/PipeTsFileResourceSegmentLock.java | 9 +-
.../hardlink/PipeWALHardlinkResourceManager.java | 20 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 10 +
.../load/LoadTsFileToTreeModelAnalyzer.java | 10 +
.../iotdb/db/storageengine/buffer/ChunkCache.java | 12 +-
.../db/storageengine/dataregion/DataRegion.java | 6 -
.../fast/reader/CompactionAlignedChunkReader.java | 18 +-
.../fast/reader/CompactionChunkReader.java | 14 +-
.../readchunk/loader/InstantChunkLoader.java | 3 +-
.../readchunk/loader/InstantPageLoader.java | 17 +-
.../compaction/repair/RepairDataFileScanUtil.java | 17 +-
.../dataregion/flush/FlushManager.java | 20 +-
.../filescan/impl/DiskAlignedChunkHandleImpl.java | 11 +-
.../read/filescan/impl/DiskChunkHandleImpl.java | 7 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 2 +-
.../dataregion/utils/SharedTimeDataBuffer.java | 8 +-
.../conf/iotdb-system.properties.template | 15 ++
.../container/PipeConsensusClientMgrContainer.java | 22 +--
.../apache/iotdb/commons/conf/CommonConfig.java | 8 -
.../commons/pipe/agent/task/PipeTaskManager.java | 7 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 40 ++--
pom.xml | 3 +-
51 files changed, 727 insertions(+), 190 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/query/{IoTDBQueryDemoIT.java
=> IoTDBEncryptionValueQueryIT.java} (99%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBLoadEncryptedTsFileIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBRepairDataIT.java
=> query/IoTDBLoadPlainTsFileIT.java} (53%)
