diff --git a/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/GeoIpTaskState.java b/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/GeoIpTaskState.java index c9062a3443e87..151e17ae879e7 100644 --- a/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/GeoIpTaskState.java +++ b/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/GeoIpTaskState.java @@ -69,7 +69,7 @@ public static GeoIpTaskState fromXContent(XContentParser parser) throws IOExcept in -> { long lastUpdate = in.readLong(); return new Metadata(lastUpdate, in.readVInt(), in.readVInt(), in.readString(), - in.getVersion().onOrAfter(Version.V_8_0_0) ? in.readLong() : lastUpdate); + in.getVersion().onOrAfter(Version.V_7_14_0) ? in.readLong() : lastUpdate); })); } @@ -135,7 +135,7 @@ public void writeTo(StreamOutput out) throws IOException { o.writeVInt(v.firstChunk); o.writeVInt(v.lastChunk); o.writeString(v.md5); - if (o.getVersion().onOrAfter(Version.V_8_0_0)) { + if (o.getVersion().onOrAfter(Version.V_7_14_0)) { o.writeLong(v.lastCheck); } }); diff --git a/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/stats/GeoIpDownloaderStats.java b/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/stats/GeoIpDownloaderStats.java index d368127b30cd9..f87c276741fe6 100644 --- a/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/stats/GeoIpDownloaderStats.java +++ b/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/stats/GeoIpDownloaderStats.java @@ -59,7 +59,7 @@ public GeoIpDownloaderStats(StreamInput in) throws IOException { totalDownloadTime = in.readVLong(); databasesCount = in.readVInt(); skippedDownloads = in.readVInt(); - if (in.getVersion().onOrAfter(Version.V_8_0_0)) { + if (in.getVersion().onOrAfter(Version.V_7_14_0)) { expiredDatabases = in.readVInt(); } else { expiredDatabases = 0; @@ -149,7 +149,7 @@ public void writeTo(StreamOutput out) throws IOException { out.writeVLong(totalDownloadTime); out.writeVInt(databasesCount); out.writeVInt(skippedDownloads); - if (out.getVersion().onOrAfter(Version.V_8_0_0)) { + if (out.getVersion().onOrAfter(Version.V_7_14_0)) { out.writeVInt(expiredDatabases); } }