This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch fix_aligned_timeseries_point_loss
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 759e2d2cb75 Fix aligned timeseries may loss point after flush
add 212a72d0a01 Refactor Compaction recover and exception handle logic
(#11349)
add a45e4414dd1 Use bash instead of sh in integration test
add 6f6f6425c7f [IOTDB-6197] Improvements on periodic snapshot guardian
(#11342)
add ce4fc833223 [IOTDB-6194] Remove _list from parameter
target_config_node_list (#11335)
add 0118acaa963 Fix partition interval may be not set correctly
add 7759b8747a7 Add SLEEP_BOUND for the DriverTaskTimeoutSentinelThread
add 3602124f76b Fix auth upgrade 1.2 (#11355)
add f155b8ce5ab Merge branch 'master' of github.com:apache/iotdb into
fix_aligned_timeseries_point_loss
add d7db82f889e fix review
No new revisions were added by this update.
Summary of changes:
.../DockerCompose/docker-compose-cluster-1c2d.yml | 6 +-
.../DockerCompose/docker-compose-host-3c3d.yml | 4 +-
.../DockerCompose/docker-compose-standalone.yml | 4 +-
docker/src/main/Dockerfile-1c1d | 4 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 6 +-
.../it/env/cluster/node/ConfigNodeWrapper.java | 9 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 4 +-
.../apache/iotdb/cli/it/StartClientScriptIT.java | 4 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 42 +
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 41 -
.../org/apache/iotdb/tools/ExportCsvTestIT.java | 4 +-
.../org/apache/iotdb/tools/ExportTsFileTestIT.java | 4 +-
.../iotdb/tool/integration/ExportCsvTestIT.java | 2 +-
.../iotdb/tool/integration/ImportCsvTestIT.java | 2 +-
.../resources/conf/iotdb-confignode.properties | 9 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 41 +-
.../confignode/conf/ConfigNodeDescriptor.java | 44 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 10 +-
.../manager/consensus/ConsensusManager.java | 4 +-
.../manager/node/ClusterNodeStartUtils.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 5 +
.../iotdb/confignode/persistence/AuthorInfo.java | 6 +-
.../iotdb/confignode/service/ConfigNode.java | 14 +-
.../confignode/service/ConfigNodeShutdownHook.java | 6 +-
.../confignode/persistence/AuthorInfoTest.java | 987 ++++++++-------------
.../confignode1conf/iotdb-confignode.properties | 2 +-
.../confignode2conf/iotdb-confignode.properties | 2 +-
.../confignode3conf/iotdb-confignode.properties | 2 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 53 +-
.../apache/iotdb/consensus/ratis/DiskGuardian.java | 252 ++++++
.../iotdb/consensus/ratis/RatisConsensus.java | 71 +-
.../consensus/ratis/utils/RatisLogMonitor.java | 88 --
.../iotdb/consensus/ratis/DiskGuardianTest.java | 120 +++
.../iotdb/consensus/ratis/RatisConsensusTest.java | 4 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 7 +-
.../resources/conf/iotdb-datanode.properties | 7 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 31 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 25 +-
.../db/consensus/DataRegionConsensusImpl.java | 4 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 4 +-
.../execution/schedule/DriverScheduler.java | 7 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 18 +-
.../execution/schedule/ITaskScheduler.java | 8 +
.../java/org/apache/iotdb/db/service/DataNode.java | 8 +-
...eption.java => CompactionRecoverException.java} | 8 +-
.../execute/recover/CompactionRecoverManager.java | 20 -
.../execute/recover/CompactionRecoverTask.java | 238 +----
.../execute/task/AbstractCompactionTask.java | 138 ++-
.../execute/task/CrossSpaceCompactionTask.java | 164 +++-
.../execute/task/InnerSpaceCompactionTask.java | 189 ++--
.../execute/utils/log/CompactionLogAnalyzer.java | 121 +--
.../execute/utils/log/CompactionLogger.java | 18 +-
.../utils/log/CompactionTaskStage.java} | 36 +-
.../SimpleCompactionLogger.java} | 35 +-
.../execute/utils/log/TsFileIdentifier.java | 30 -
.../db/auth/role/LocalFileRoleAccessorTest.java | 90 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 21 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 106 ++-
.../db/auth/user/LocalFileUserManagerTest.java | 22 +-
.../compaction/AbstractCompactionTest.java | 3 +
.../CrossSpaceCompactionWithFastPerformerTest.java | 26 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 26 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 413 ---------
.../SizeTieredCompactionRecoverCompatibleTest.java | 276 ------
.../recover/SizeTieredCompactionRecoverTest.java | 588 ++++++++----
.../datanode1conf/iotdb-datanode.properties | 2 +-
.../datanode2conf/iotdb-datanode.properties | 2 +-
.../datanode3conf/iotdb-datanode.properties | 2 +-
.../src/test/resources/iotdb-datanode.properties | 1 +
.../resources/conf/iotdb-common.properties | 5 +
.../commons/auth/entity/PriPrivilegeType.java | 118 ++-
.../iotdb/commons/auth/user/BasicUserManager.java | 2 +-
.../iotdb/commons/conf/CommonDescriptor.java | 2 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 4 +-
.../src/main/thrift/confignode.thrift | 3 +
75 files changed, 2181 insertions(+), 2507 deletions(-)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/DiskGuardian.java
delete mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/RatisLogMonitor.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/DiskGuardianTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/{CompactionValidationFailedException.java
=> CompactionRecoverException.java} (80%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{tool/Interval.java
=> execute/utils/log/CompactionTaskStage.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/{validator/NoneCompactionValidator.java
=> log/SimpleCompactionLogger.java} (54%)
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/recover/RewriteCrossSpaceCompactionRecoverCompatibleTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/recover/SizeTieredCompactionRecoverCompatibleTest.java
