From f06b4fbbaf272a6ed57941cbf9e005f07270e731 Mon Sep 17 00:00:00 2001
From: David Kyle <david.kyle@elastic.co>
Date: Wed, 22 Feb 2017 13:52:38 +0000
Subject: [PATCH] [ML] remove duplicate code

Original commit: elastic/x-pack-elasticsearch@340480477cbf576975ce8863bd359f2da0dc2b19
---
 .../org/elasticsearch/xpack/ml/action/FlushJobAction.java     | 3 +--
 .../xpack/ml/action/PostDataFlushRequestTests.java            | 4 ++++
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/plugin/src/main/java/org/elasticsearch/xpack/ml/action/FlushJobAction.java b/plugin/src/main/java/org/elasticsearch/xpack/ml/action/FlushJobAction.java
index 499e569e6db..3844c8f0cb0 100644
--- a/plugin/src/main/java/org/elasticsearch/xpack/ml/action/FlushJobAction.java
+++ b/plugin/src/main/java/org/elasticsearch/xpack/ml/action/FlushJobAction.java
@@ -31,7 +31,6 @@ import org.elasticsearch.xpack.ml.job.config.Job;
 import org.elasticsearch.xpack.ml.job.process.autodetect.AutodetectProcessManager;
 import org.elasticsearch.xpack.ml.job.process.autodetect.params.InterimResultsParams;
 import org.elasticsearch.xpack.ml.job.process.autodetect.params.TimeRange;
-import org.elasticsearch.xpack.ml.utils.ExceptionsHelper;
 
 import java.io.IOException;
 import java.util.Objects;
@@ -89,7 +88,7 @@ public class FlushJobAction extends Action<FlushJobAction.Request, FlushJobActio
         }
 
         public Request(String jobId) {
-            this.jobId = ExceptionsHelper.requireNonNull(jobId, Job.ID.getPreferredName());
+            super(jobId);
         }
 
         public boolean getCalcInterim() {
diff --git a/plugin/src/test/java/org/elasticsearch/xpack/ml/action/PostDataFlushRequestTests.java b/plugin/src/test/java/org/elasticsearch/xpack/ml/action/PostDataFlushRequestTests.java
index 04c904d0f76..a7a55702e09 100644
--- a/plugin/src/test/java/org/elasticsearch/xpack/ml/action/PostDataFlushRequestTests.java
+++ b/plugin/src/test/java/org/elasticsearch/xpack/ml/action/PostDataFlushRequestTests.java
@@ -30,4 +30,8 @@ public class PostDataFlushRequestTests extends AbstractStreamableTestCase<Reques
     protected Request createBlankInstance() {
         return new Request();
     }
+
+    public void testNullJobIdThrows() {
+        expectThrows(IllegalArgumentException.class, () -> new Request(null));
+    }
 }
\ No newline at end of file