From fc6a31e141b0e0b720e88c2456c48bba25c336ab Mon Sep 17 00:00:00 2001
From: Ryan Ernst <ryan@elastic.co>
Date: Sun, 14 Jul 2019 19:04:53 -0700
Subject: [PATCH] Use specific version constant for wire bwc check (#44316)

This commit modifies bwc behavior in FindFileStructureAction to check
against a concrete version instead of Version.CURRENT. Checking against
Version.CURRENT does not work since it is changing, in addition to it
having different meanings on each branch.

relates #42501
---
 .../xpack/core/ml/action/FindFileStructureAction.java         | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/FindFileStructureAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/FindFileStructureAction.java
index 7baa907f2e5..14222075d60 100644
--- a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/FindFileStructureAction.java
+++ b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/FindFileStructureAction.java
@@ -338,7 +338,7 @@ public class FindFileStructureAction extends StreamableResponseActionType<FindFi
         public void readFrom(StreamInput in) throws IOException {
             super.readFrom(in);
             linesToSample = in.readOptionalVInt();
-            if (in.getVersion().onOrAfter(Version.CURRENT)) {
+            if (in.getVersion().onOrAfter(Version.V_7_3_0)) {
                 lineMergeSizeLimit = in.readOptionalVInt();
             }
             timeout = in.readOptionalTimeValue();
@@ -359,7 +359,7 @@ public class FindFileStructureAction extends StreamableResponseActionType<FindFi
         public void writeTo(StreamOutput out) throws IOException {
             super.writeTo(out);
             out.writeOptionalVInt(linesToSample);
-            if (out.getVersion().onOrAfter(Version.CURRENT)) {
+            if (out.getVersion().onOrAfter(Version.V_7_3_0)) {
                 out.writeOptionalVInt(lineMergeSizeLimit);
             }
             out.writeOptionalTimeValue(timeout);