From 69f570ea5f7216c4884c7428f60b862eaa1a9f89 Mon Sep 17 00:00:00 2001 From: Jason Tedor Date: Fri, 22 Nov 2019 14:42:23 -0500 Subject: [PATCH] Adjust version on final pipeline serialization This commit adjusts the version final pipeline serialization after it was backported to the 7.5 branch. --- .../java/org/elasticsearch/action/index/IndexRequest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/elasticsearch/action/index/IndexRequest.java b/server/src/main/java/org/elasticsearch/action/index/IndexRequest.java index 53d84dab02c..54f19431ef8 100644 --- a/server/src/main/java/org/elasticsearch/action/index/IndexRequest.java +++ b/server/src/main/java/org/elasticsearch/action/index/IndexRequest.java @@ -134,7 +134,7 @@ public class IndexRequest extends ReplicatedWriteRequest implement version = in.readLong(); versionType = VersionType.fromValue(in.readByte()); pipeline = in.readOptionalString(); - if (in.getVersion().onOrAfter(Version.V_7_6_0)) { + if (in.getVersion().onOrAfter(Version.V_7_5_0)) { finalPipeline = in.readOptionalString(); } if (in.getVersion().onOrAfter(Version.V_7_5_0)) { @@ -713,7 +713,7 @@ public class IndexRequest extends ReplicatedWriteRequest implement out.writeLong(version); out.writeByte(versionType.getValue()); out.writeOptionalString(pipeline); - if (out.getVersion().onOrAfter(Version.V_7_6_0)) { + if (out.getVersion().onOrAfter(Version.V_7_5_0)) { out.writeOptionalString(finalPipeline); } if (out.getVersion().onOrAfter(Version.V_7_5_0)) {