From de99f400c617d047783feeafe8452a2ab5bb247e Mon Sep 17 00:00:00 2001 From: Bryan Burkholder <771133+bryanlb@users.noreply.github.com> Date: Thu, 8 Feb 2024 16:13:59 -0700 Subject: [PATCH] Bump hardcoded max rollover time, allow overriding default (#766) Co-authored-by: Bryan Burkholder --- .../com/slack/kaldb/chunkManager/RecoveryChunkManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kaldb/src/main/java/com/slack/kaldb/chunkManager/RecoveryChunkManager.java b/kaldb/src/main/java/com/slack/kaldb/chunkManager/RecoveryChunkManager.java index 8e7067cb7d..f7fc03fc30 100644 --- a/kaldb/src/main/java/com/slack/kaldb/chunkManager/RecoveryChunkManager.java +++ b/kaldb/src/main/java/com/slack/kaldb/chunkManager/RecoveryChunkManager.java @@ -41,7 +41,8 @@ public class RecoveryChunkManager extends ChunkManagerBase { private static final Logger LOG = LoggerFactory.getLogger(RecoveryChunkManager.class); // This field controls the maximum amount of time we wait for a rollover to complete. - private static final int MAX_ROLLOVER_MINUTES = 20; + private static final int MAX_ROLLOVER_MINUTES = + Integer.parseInt(System.getProperty("kalDb.recovery.maxRolloverMins", "90")); private final ChunkFactory recoveryChunkFactory; private final ChunkRolloverFactory chunkRolloverFactory;