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;