summaryrefslogtreecommitdiff
path: root/core/src/main/java/org/elasticsearch/search/fetch/subphase/VersionFetchSubPhase.java
diff options
context:
space:
mode:
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.java4
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);