diff --git a/kaldb/src/main/java/com/slack/kaldb/server/RecoveryTaskCreator.java b/kaldb/src/main/java/com/slack/kaldb/server/RecoveryTaskCreator.java index 17b5b63f9a..dca25b4267 100644 --- a/kaldb/src/main/java/com/slack/kaldb/server/RecoveryTaskCreator.java +++ b/kaldb/src/main/java/com/slack/kaldb/server/RecoveryTaskCreator.java @@ -218,8 +218,9 @@ public long determineStartingOffset( } else if (indexerConfig.getCreateRecoveryTasksOnStart() && indexerConfig.getReadFromLocationOnStart() == KaldbConfigs.KafkaOffsetLocation.LATEST) { - // todo - this appears to be able to create recovery tasks that have a start and end - // position of 0, which is invalid + // Todo - this appears to be able to create recovery tasks that have a start and end + // position of 0, which is invalid. This seems to occur when new clusters are initialized, and is + // especially problematic when indexers are created but never get assigned (ie, deploy 5, only assign 3). LOG.info( "CreateRecoveryTasksOnStart is set and ReadLocationOnStart is set to current. Reading from current and" + " spinning up recovery tasks");