summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorPisarenko Grigoriy <[email protected]>2025-09-15 14:28:12 +0500
committerGitHub <[email protected]>2025-09-15 12:28:12 +0300
commit9635130acf46fc731fcdc6511f128ead7446a638 (patch)
tree621e919e7ad88e65caa0317ae5226675672bd683
parenteb669650729feb332ba39102178d7eb9e2668118 (diff)
YQ-4675 made checkpoint period 30s by default (#24878)
-rw-r--r--ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp2
-rw-r--r--ydb/core/fq/libs/config/protos/checkpoint_coordinator.proto2
-rw-r--r--ydb/core/protos/config.proto2
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.
}