This commit is contained in:
parent
30a0f6643d
commit
40398e1192
@ -239,7 +239,7 @@ public class EditBatchProcessor {
|
|||||||
Thread.sleep(sleepTime);
|
Thread.sleep(sleepTime);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (currentDocs == null) {
|
if (currentDocs == null && !qidsToFetch.isEmpty()) {
|
||||||
logger.warn("Giving up on fetching documents to edit. Skipping "+remainingEdits()+" remaining edits.");
|
logger.warn("Giving up on fetching documents to edit. Skipping "+remainingEdits()+" remaining edits.");
|
||||||
globalCursor = scheduled.size();
|
globalCursor = scheduled.size();
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user