diff options
Diffstat (limited to 'core/src/main/java/org/elasticsearch/search/fetch/subphase/VersionFetchSubPhase.java')
-rw-r--r-- | core/src/main/java/org/elasticsearch/search/fetch/subphase/VersionFetchSubPhase.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/java/org/elasticsearch/search/fetch/subphase/VersionFetchSubPhase.java b/core/src/main/java/org/elasticsearch/search/fetch/subphase/VersionFetchSubPhase.java index 1ce102e364..5f69230ca4 100644 --- a/core/src/main/java/org/elasticsearch/search/fetch/subphase/VersionFetchSubPhase.java +++ b/core/src/main/java/org/elasticsearch/search/fetch/subphase/VersionFetchSubPhase.java @@ -38,8 +38,8 @@ public final class VersionFetchSubPhase implements FetchSubPhase { long version = Versions.NOT_FOUND; try { NumericDocValues versions = hitContext.reader().getNumericDocValues(VersionFieldMapper.NAME); - if (versions != null) { - version = versions.get(hitContext.docId()); + if (versions != null && versions.advanceExact(hitContext.docId())) { + version = versions.longValue(); } } catch (IOException e) { throw new ElasticsearchException("Could not retrieve version", e); |