diff options
author | Pisarenko Grigoriy <[email protected]> | 2025-09-15 14:28:12 +0500 |
---|---|---|
committer | GitHub <[email protected]> | 2025-09-15 12:28:12 +0300 |
commit | 9635130acf46fc731fcdc6511f128ead7446a638 (patch) | |
tree | 621e919e7ad88e65caa0317ae5226675672bd683 | |
parent | eb669650729feb332ba39102178d7eb9e2668118 (diff) |
YQ-4675 made checkpoint period 30s by default (#24878)
-rw-r--r-- | ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp | 2 | ||||
-rw-r--r-- | ydb/core/fq/libs/config/protos/checkpoint_coordinator.proto | 2 | ||||
-rw-r--r-- | ydb/core/protos/config.proto | 2 |
3 files changed, 3 insertions, 3 deletions
diff --git a/ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp b/ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp index 076f5cbf0b6..262a0423c35 100644 --- a/ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp +++ b/ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp @@ -37,7 +37,7 @@ TCheckpointCoordinator::TCheckpointCoordinator(TCoordinatorId coordinatorId, , StorageProxy(storageProxy) , RunActorId(runActorId) , Settings(settings) - , CheckpointingPeriod(TDuration::MilliSeconds(Settings.GetCheckpointingPeriodMillis())) + , CheckpointingPeriod(TDuration::MilliSeconds(Settings.GetCheckpointingPeriodMillis() ? Settings.GetCheckpointingPeriodMillis() : 30'000)) , CheckpointingSnapshotRotationPeriod(Settings.GetCheckpointingSnapshotRotationPeriod()) , CheckpointingSnapshotRotationIndex(CheckpointingSnapshotRotationPeriod) // First - snapshot , GraphParams(graphParams) diff --git a/ydb/core/fq/libs/config/protos/checkpoint_coordinator.proto b/ydb/core/fq/libs/config/protos/checkpoint_coordinator.proto index bbbf01b4a2c..88dc8a4652a 100644 --- a/ydb/core/fq/libs/config/protos/checkpoint_coordinator.proto +++ b/ydb/core/fq/libs/config/protos/checkpoint_coordinator.proto @@ -23,7 +23,7 @@ message TCheckpointCoordinatorConfig { TYdbStorageConfig Storage = 2; TCheckpointGcConfig CheckpointGarbageConfig = 3; TStateStorageLimitsConfig StateStorageLimits = 4; - uint64 CheckpointingPeriodMillis = 5; + uint64 CheckpointingPeriodMillis = 5; // 30s by default uint64 MaxInflight = 6; uint64 CheckpointingSnapshotRotationPeriod = 7; // 0 - All checkpoints are snapshots, 1 - 1 increment/ 1 snapshot, 20 - 20 incrrement / 1 snapshot. } diff --git a/ydb/core/protos/config.proto b/ydb/core/protos/config.proto index 99fad5740bd..64b898eb12a 100644 --- a/ydb/core/protos/config.proto +++ b/ydb/core/protos/config.proto @@ -1185,7 +1185,7 @@ message TCheckpointsConfig { } optional TCheckpointGcConfig CheckpointGarbageConfig = 4; optional TStateStorageLimitsConfig StateStorageLimits = 5; - optional uint64 CheckpointingPeriodMillis = 6; + optional uint64 CheckpointingPeriodMillis = 6 [default = 30000]; optional uint64 MaxInflight = 7; optional uint64 CheckpointingSnapshotRotationPeriod = 8; // 0 - All checkpoints are snapshots, 1 - 1 increment/ 1 snapshot, 20 - 20 increment / 1 snapshot. } |