flushNeeded = true;
} catch (Throwable t) {
maybeFailEngine(t);
throw new DeleteByQueryFailedEngineException(shardId, delete, t);
}
<BUG>refreshVersioningTable(System.currentTimeMillis());
</BUG>
}
@Override
public final Searcher acquireSearcher(String source) throws EngineException {

flushNeeded = true;
} catch (Throwable t) {
maybeFailEngine(t);
throw new DeleteByQueryFailedEngineException(shardId, delete, t);
}
pruneDeletedVersions(System.currentTimeMillis());
}
@Override
public final Searcher acquireSearcher(String source) throws EngineException {
