浏览代码

[ML] adjusting bwc serialization for #77256 (#77257)

Benjamin Trent 4 年之前
父节点
当前提交
222d95af53

+ 2 - 9
x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/PutTrainedModelAction.java

@@ -6,7 +6,6 @@
  */
  */
 package org.elasticsearch.xpack.core.ml.action;
 package org.elasticsearch.xpack.core.ml.action;
 
 
-import org.elasticsearch.Version;
 import org.elasticsearch.action.ActionRequestValidationException;
 import org.elasticsearch.action.ActionRequestValidationException;
 import org.elasticsearch.action.ActionResponse;
 import org.elasticsearch.action.ActionResponse;
 import org.elasticsearch.action.ActionType;
 import org.elasticsearch.action.ActionType;
@@ -65,11 +64,7 @@ public class PutTrainedModelAction extends ActionType<PutTrainedModelAction.Resp
         public Request(StreamInput in) throws IOException {
         public Request(StreamInput in) throws IOException {
             super(in);
             super(in);
             this.config = new TrainedModelConfig(in);
             this.config = new TrainedModelConfig(in);
-            if (in.getVersion().onOrAfter(Version.V_8_0_0)) {
-                this.deferDefinitionDecompression = in.readBoolean();
-            } else {
-                this.deferDefinitionDecompression = false;
-            }
+            this.deferDefinitionDecompression = in.readBoolean();
         }
         }
 
 
         public TrainedModelConfig getTrainedModelConfig() {
         public TrainedModelConfig getTrainedModelConfig() {
@@ -100,9 +95,7 @@ public class PutTrainedModelAction extends ActionType<PutTrainedModelAction.Resp
         public void writeTo(StreamOutput out) throws IOException {
         public void writeTo(StreamOutput out) throws IOException {
             super.writeTo(out);
             super.writeTo(out);
             config.writeTo(out);
             config.writeTo(out);
-            if (out.getVersion().onOrAfter(Version.V_8_0_0)) {
-                out.writeBoolean(deferDefinitionDecompression);
-            }
+            out.writeBoolean(deferDefinitionDecompression);
         }
         }
 
 
         @Override
         @Override