[ML-DataFrame] fix wire serialization issues in data frame response objects (#39790)

Hendrik Muhs · Hendrik Muhs · commit 4d41310be567 · 2019-03-07T19:28:44.000+01:00
fix wire serialization issues in data frame response objects
diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/dataframe/action/DeleteDataFrameTransformAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/dataframe/action/DeleteDataFrameTransformAction.java
@@ -49,7 +49,7 @@ public Request(String id) {
             this.id = ExceptionsHelper.requireNonNull(id, DataFrameField.ID.getPreferredName());
         }
 
-        public Request() {
+        private Request() {
         }
 
         public Request(StreamInput in) throws IOException {
@@ -113,7 +113,7 @@ protected RequestBuilder(ElasticsearchClient client, DeleteDataFrameTransformAct
     public static class Response extends BaseTasksResponse implements Writeable, ToXContentObject {
         private boolean acknowledged;
         public Response(StreamInput in) throws IOException {
-            super(Collections.emptyList(), Collections.emptyList());
+            super(in);
             readFrom(in);
         }
 
diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/dataframe/action/GetDataFrameTransformsAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/dataframe/action/GetDataFrameTransformsAction.java
@@ -63,7 +63,7 @@ public Request(String id) {
             }
         }
 
-        public Request() {}
+        private Request() {}
 
         public Request(StreamInput in) throws IOException {
             super(in);
@@ -149,7 +149,7 @@ public Response() {
         }
 
         public Response(StreamInput in) throws IOException {
-            super(Collections.emptyList(), Collections.emptyList());
+            super(in);
             readFrom(in);
         }
 
@@ -173,6 +173,7 @@ public void writeTo(StreamOutput out) throws IOException {
         public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
             List<String> invalidTransforms = new ArrayList<>();
             builder.startObject();
+            toXContentCommon(builder, params);
             builder.field(DataFrameField.COUNT.getPreferredName(), transformConfigurations.size());
             // XContentBuilder does not support passing the params object for Iterables
             builder.field(DataFrameField.TRANSFORMS.getPreferredName());
diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/dataframe/action/GetDataFrameTransformsStatsAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/dataframe/action/GetDataFrameTransformsStatsAction.java
@@ -55,7 +55,7 @@ public Request(String id) {
             }
         }
 
-        public Request() {}
+        private Request() {}
 
         public Request(StreamInput in) throws IOException {
             super(in);
@@ -138,7 +138,7 @@ public Response() {
         }
 
         public Response(StreamInput in) throws IOException {
-            super(Collections.emptyList(), Collections.emptyList());
+            super(in);
             readFrom(in);
         }
 
@@ -161,6 +161,7 @@ public void writeTo(StreamOutput out) throws IOException {
         @Override
         public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
             builder.startObject();
+            toXContentCommon(builder, params);
             builder.field(DataFrameField.COUNT.getPreferredName(), transformsStateAndStats.size());
             builder.field(DataFrameField.TRANSFORMS.getPreferredName(), transformsStateAndStats);
             builder.endObject();
diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/dataframe/action/StartDataFrameTransformAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/dataframe/action/StartDataFrameTransformAction.java
@@ -46,7 +46,7 @@ public Request(String id) {
             this.id = ExceptionsHelper.requireNonNull(id, DataFrameField.ID.getPreferredName());
         }
 
-        public Request() {
+        private Request() {
         }
 
         public Request(StreamInput in) throws IOException {
@@ -108,7 +108,7 @@ public Response() {
         }
 
         public Response(StreamInput in) throws IOException {
-            super(Collections.emptyList(), Collections.emptyList());
+            super(in);
             readFrom(in);
         }
 
@@ -136,6 +136,7 @@ public void writeTo(StreamOutput out) throws IOException {
         @Override
         public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
             builder.startObject();
+            toXContentCommon(builder, params);
             builder.field("started", started);
             builder.endObject();
             return builder;
diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/dataframe/action/StopDataFrameTransformAction.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/dataframe/action/StopDataFrameTransformAction.java
@@ -56,7 +56,7 @@ public Request(String id, boolean waitForCompletion, @Nullable TimeValue timeout
             this.setTimeout(timeout == null ? DEFAULT_TIMEOUT : timeout);
         }
 
-        public Request() {
+        private Request() {
             this(null, false, null);
         }
 
@@ -149,7 +149,7 @@ public Response() {
         }
 
         public Response(StreamInput in) throws IOException {
-            super(Collections.emptyList(), Collections.emptyList());
+            super(in);
             readFrom(in);
         }
 
@@ -177,6 +177,7 @@ public void writeTo(StreamOutput out) throws IOException {
         @Override
         public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
             builder.startObject();
+            toXContentCommon(builder, params);
             builder.field("stopped", stopped);
             builder.endObject();
             return builder;
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/AbstractWireSerializingDataFrameTestCase.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/AbstractWireSerializingDataFrameTestCase.java
@@ -0,0 +1,44 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+package org.elasticsearch.xpack.core.dataframe.action;
+
+import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
+import org.elasticsearch.common.io.stream.Writeable;
+import org.elasticsearch.common.settings.Settings;
+import org.elasticsearch.common.xcontent.NamedXContentRegistry;
+import org.elasticsearch.search.SearchModule;
+import org.elasticsearch.test.AbstractWireSerializingTestCase;
+import org.junit.Before;
+
+import static java.util.Collections.emptyList;
+
+public abstract class AbstractWireSerializingDataFrameTestCase<T extends Writeable> extends AbstractWireSerializingTestCase<T> {
+    /**
+     * Test case that ensures aggregation named objects are registered
+     */
+    private NamedWriteableRegistry namedWriteableRegistry;
+    private NamedXContentRegistry namedXContentRegistry;
+
+    @Before
+    public void registerAggregationNamedObjects() throws Exception {
+        // register aggregations as NamedWriteable
+        SearchModule searchModule = new SearchModule(Settings.EMPTY, false, emptyList());
+
+        namedWriteableRegistry = new NamedWriteableRegistry(searchModule.getNamedWriteables());
+        namedXContentRegistry = new NamedXContentRegistry(searchModule.getNamedXContents());
+    }
+
+    @Override
+    protected NamedWriteableRegistry getNamedWriteableRegistry() {
+        return namedWriteableRegistry;
+    }
+
+    @Override
+    protected NamedXContentRegistry xContentRegistry() {
+        return namedXContentRegistry;
+    }
+}
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/DeleteDataFrameTransformActionResponseTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/DeleteDataFrameTransformActionResponseTests.java
@@ -0,0 +1,22 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+package org.elasticsearch.xpack.core.dataframe.action;
+
+import org.elasticsearch.common.io.stream.Writeable.Reader;
+import org.elasticsearch.xpack.core.dataframe.action.DeleteDataFrameTransformAction.Response;
+
+public class DeleteDataFrameTransformActionResponseTests extends AbstractWireSerializingDataFrameTestCase<Response> {
+    @Override
+    protected Response createTestInstance() {
+        return new Response(randomBoolean());
+    }
+
+    @Override
+    protected Reader<Response> instanceReader() {
+        return Response::new;
+    }
+}
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/GetDataFrameTransformsActionResponseTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/GetDataFrameTransformsActionResponseTests.java
@@ -6,23 +6,23 @@
 
 package org.elasticsearch.xpack.core.dataframe.action;
 
+import org.elasticsearch.common.io.stream.Writeable.Reader;
 import org.elasticsearch.common.logging.LoggerMessageFormat;
 import org.elasticsearch.common.xcontent.XContentBuilder;
 import org.elasticsearch.common.xcontent.XContentFactory;
 import org.elasticsearch.common.xcontent.XContentType;
 import org.elasticsearch.common.xcontent.support.XContentMapValues;
-import org.elasticsearch.test.ESTestCase;
-import org.elasticsearch.xpack.core.watcher.watch.Payload.XContent;
 import org.elasticsearch.xpack.core.dataframe.action.GetDataFrameTransformsAction.Response;
 import org.elasticsearch.xpack.core.dataframe.transforms.DataFrameTransformConfig;
 import org.elasticsearch.xpack.core.dataframe.transforms.DataFrameTransformConfigTests;
+import org.elasticsearch.xpack.core.watcher.watch.Payload.XContent;
 
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
-public class GetDataFrameTransformsActionResponseTests extends ESTestCase {
+public class GetDataFrameTransformsActionResponseTests extends AbstractWireSerializingDataFrameTestCase<Response> {
 
     public void testInvalidTransforms() throws IOException {
         List<DataFrameTransformConfig> transforms = new ArrayList<>();
@@ -66,4 +66,19 @@ public void testNoHeaderInResponse() throws IOException {
             assertEquals(null, XContentMapValues.extractValue("headers", transformsResponse.get(i)));
         }
     }
+
+    @Override
+    protected Response createTestInstance() {
+        List<DataFrameTransformConfig> configs = new ArrayList<>();
+        for (int i = 0; i < randomInt(10); ++i) {
+            configs.add(DataFrameTransformConfigTests.randomDataFrameTransformConfig());
+        }
+
+        return new Response(configs);
+    }
+
+    @Override
+    protected Reader<Response> instanceReader() {
+        return Response::new;
+    }
 }
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/GetDataFrameTransformsStatsActionResponseTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/GetDataFrameTransformsStatsActionResponseTests.java
@@ -0,0 +1,32 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+package org.elasticsearch.xpack.core.dataframe.action;
+
+import org.elasticsearch.common.io.stream.Writeable.Reader;
+import org.elasticsearch.xpack.core.dataframe.action.GetDataFrameTransformsStatsAction.Response;
+import org.elasticsearch.xpack.core.dataframe.transforms.DataFrameTransformStateAndStats;
+import org.elasticsearch.xpack.core.dataframe.transforms.DataFrameTransformStateAndStatsTests;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class GetDataFrameTransformsStatsActionResponseTests extends AbstractWireSerializingDataFrameTestCase<Response> {
+    @Override
+    protected Response createTestInstance() {
+        List<DataFrameTransformStateAndStats> stats = new ArrayList<>();
+        for (int i = 0; i < randomInt(10); ++i) {
+            stats.add(DataFrameTransformStateAndStatsTests.randomDataFrameTransformStateAndStats());
+        }
+
+        return new Response(stats);
+    }
+
+    @Override
+    protected Reader<Response> instanceReader() {
+        return Response::new;
+    }
+}
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/PreviewDataFrameTransformsActionResponseWireTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/PreviewDataFrameTransformsActionResponseWireTests.java
@@ -0,0 +1,38 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+package org.elasticsearch.xpack.core.dataframe.action;
+
+import org.elasticsearch.common.io.stream.Writeable.Reader;
+import org.elasticsearch.xpack.core.dataframe.action.PreviewDataFrameTransformAction.Response;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class PreviewDataFrameTransformsActionResponseWireTests extends AbstractWireSerializingDataFrameTestCase<Response> {
+
+    @Override
+    protected Response createTestInstance() {
+        int size = randomIntBetween(0, 10);
+        List<Map<String, Object>> data = new ArrayList<>(size);
+        for (int i = 0; i < size; i++) {
+            Map<String, Object> datum = new HashMap<>();
+            Map<String, Object> entry = new HashMap<>();
+            entry.put("value1", randomIntBetween(1, 100));
+            datum.put(randomAlphaOfLength(10), entry);
+            data.add(datum);
+        }
+        return new Response(data);
+    }
+
+    @Override
+    protected Reader<Response> instanceReader() {
+        return Response::new;
+    }
+
+}
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/PutDataFrameTransformActionResponseTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/PutDataFrameTransformActionResponseTests.java
@@ -0,0 +1,24 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+package org.elasticsearch.xpack.core.dataframe.action;
+
+import org.elasticsearch.test.AbstractStreamableTestCase;
+import org.elasticsearch.xpack.core.dataframe.action.PutDataFrameTransformAction.Response;
+
+public class PutDataFrameTransformActionResponseTests extends AbstractStreamableTestCase<Response> {
+
+    @Override
+    protected Response createBlankInstance() {
+        return new Response();
+    }
+
+    @Override
+    protected Response createTestInstance() {
+        return new Response(randomBoolean());
+    }
+
+}
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/StartDataFrameTransformActionRequestTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/StartDataFrameTransformActionRequestTests.java
@@ -10,7 +10,7 @@
 import org.elasticsearch.test.AbstractWireSerializingTestCase;
 import org.elasticsearch.xpack.core.dataframe.action.StartDataFrameTransformAction.Request;
 
-public class StartDataFrameTransformActionTests extends AbstractWireSerializingTestCase<Request> {
+public class StartDataFrameTransformActionRequestTests extends AbstractWireSerializingTestCase<Request> {
     @Override
     protected Request createTestInstance() {
         return new Request(randomAlphaOfLengthBetween(1, 20));
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/StartDataFrameTransformActionResponseTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/StartDataFrameTransformActionResponseTests.java
@@ -0,0 +1,24 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+package org.elasticsearch.xpack.core.dataframe.action;
+
+import org.elasticsearch.common.io.stream.Writeable.Reader;
+import org.elasticsearch.xpack.core.dataframe.action.StartDataFrameTransformAction.Response;
+
+public class StartDataFrameTransformActionResponseTests extends AbstractWireSerializingDataFrameTestCase<Response> {
+
+    @Override
+    protected Response createTestInstance() {
+        return new Response(randomBoolean());
+    }
+
+    @Override
+    protected Reader<Response> instanceReader() {
+        return Response::new;
+    }
+
+}
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/StopDataFrameTransformActionResponseTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/dataframe/action/StopDataFrameTransformActionResponseTests.java
@@ -0,0 +1,24 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+package org.elasticsearch.xpack.core.dataframe.action;
+
+import org.elasticsearch.common.io.stream.Writeable.Reader;
+import org.elasticsearch.xpack.core.dataframe.action.StopDataFrameTransformAction.Response;
+
+public class StopDataFrameTransformActionResponseTests extends AbstractWireSerializingDataFrameTestCase<Response> {
+
+    @Override
+    protected Response createTestInstance() {
+        return new Response(randomBoolean());
+    }
+
+    @Override
+    protected Reader<Response> instanceReader() {
+        return Response::new;
+    }
+
+}

Original file line number	Diff line number	Diff line change
`@@ -49,7 +49,7 @@ public Request(String id) {`
`49`	`49`	`this.id = ExceptionsHelper.requireNonNull(id, DataFrameField.ID.getPreferredName());`
`50`	`50`	`}`
`51`	`51`
`52`		`- public Request() {`
	`52`	`+ private Request() {`
`53`	`53`	`}`
`54`	`54`
`55`	`55`	`public Request(StreamInput in) throws IOException {`
`@@ -113,7 +113,7 @@ protected RequestBuilder(ElasticsearchClient client, DeleteDataFrameTransformAct`
`113`	`113`	`public static class Response extends BaseTasksResponse implements Writeable, ToXContentObject {`
`114`	`114`	`private boolean acknowledged;`
`115`	`115`	`public Response(StreamInput in) throws IOException {`
`116`		`- super(Collections.emptyList(), Collections.emptyList());`
	`116`	`+ super(in);`
`117`	`117`	`readFrom(in);`
`118`	`118`	`}`
`119`	`119`
Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ public Request(String id) {`
`63`	`63`	`}`
`64`	`64`	`}`
`65`	`65`
`66`		`- public Request() {}`
	`66`	`+ private Request() {}`
`67`	`67`
`68`	`68`	`public Request(StreamInput in) throws IOException {`
`69`	`69`	`super(in);`
`@@ -149,7 +149,7 @@ public Response() {`
`149`	`149`	`}`
`150`	`150`
`151`	`151`	`public Response(StreamInput in) throws IOException {`
`152`		`- super(Collections.emptyList(), Collections.emptyList());`
	`152`	`+ super(in);`
`153`	`153`	`readFrom(in);`
`154`	`154`	`}`
`155`	`155`
`@@ -173,6 +173,7 @@ public void writeTo(StreamOutput out) throws IOException {`
`173`	`173`	`public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {`
`174`	`174`	`List<String> invalidTransforms = new ArrayList<>();`
`175`	`175`	`builder.startObject();`
	`176`	`+ toXContentCommon(builder, params);`
`176`	`177`	`builder.field(DataFrameField.COUNT.getPreferredName(), transformConfigurations.size());`
`177`	`178`	`// XContentBuilder does not support passing the params object for Iterables`
`178`	`179`	`builder.field(DataFrameField.TRANSFORMS.getPreferredName());`
Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ public Request(String id) {`
`55`	`55`	`}`
`56`	`56`	`}`
`57`	`57`
`58`		`- public Request() {}`
	`58`	`+ private Request() {}`
`59`	`59`
`60`	`60`	`public Request(StreamInput in) throws IOException {`
`61`	`61`	`super(in);`
`@@ -138,7 +138,7 @@ public Response() {`
`138`	`138`	`}`
`139`	`139`
`140`	`140`	`public Response(StreamInput in) throws IOException {`
`141`		`- super(Collections.emptyList(), Collections.emptyList());`
	`141`	`+ super(in);`
`142`	`142`	`readFrom(in);`
`143`	`143`	`}`
`144`	`144`
`@@ -161,6 +161,7 @@ public void writeTo(StreamOutput out) throws IOException {`
`161`	`161`	`@Override`
`162`	`162`	`public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {`
`163`	`163`	`builder.startObject();`
	`164`	`+ toXContentCommon(builder, params);`
`164`	`165`	`builder.field(DataFrameField.COUNT.getPreferredName(), transformsStateAndStats.size());`
`165`	`166`	`builder.field(DataFrameField.TRANSFORMS.getPreferredName(), transformsStateAndStats);`
`166`	`167`	`builder.endObject();`
Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ public Request(String id) {`
`46`	`46`	`this.id = ExceptionsHelper.requireNonNull(id, DataFrameField.ID.getPreferredName());`
`47`	`47`	`}`
`48`	`48`
`49`		`- public Request() {`
	`49`	`+ private Request() {`
`50`	`50`	`}`
`51`	`51`
`52`	`52`	`public Request(StreamInput in) throws IOException {`
`@@ -108,7 +108,7 @@ public Response() {`
`108`	`108`	`}`
`109`	`109`
`110`	`110`	`public Response(StreamInput in) throws IOException {`
`111`		`- super(Collections.emptyList(), Collections.emptyList());`
	`111`	`+ super(in);`
`112`	`112`	`readFrom(in);`
`113`	`113`	`}`
`114`	`114`
`@@ -136,6 +136,7 @@ public void writeTo(StreamOutput out) throws IOException {`
`136`	`136`	`@Override`
`137`	`137`	`public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {`
`138`	`138`	`builder.startObject();`
	`139`	`+ toXContentCommon(builder, params);`
`139`	`140`	`builder.field("started", started);`
`140`	`141`	`builder.endObject();`
`141`	`142`	`return builder;`
Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,7 @@ public Request(String id, boolean waitForCompletion, @Nullable TimeValue timeout`
`56`	`56`	`this.setTimeout(timeout == null ? DEFAULT_TIMEOUT : timeout);`
`57`	`57`	`}`
`58`	`58`
`59`		`- public Request() {`
	`59`	`+ private Request() {`
`60`	`60`	`this(null, false, null);`
`61`	`61`	`}`
`62`	`62`
`@@ -149,7 +149,7 @@ public Response() {`
`149`	`149`	`}`
`150`	`150`
`151`	`151`	`public Response(StreamInput in) throws IOException {`
`152`		`- super(Collections.emptyList(), Collections.emptyList());`
	`152`	`+ super(in);`
`153`	`153`	`readFrom(in);`
`154`	`154`	`}`
`155`	`155`
`@@ -177,6 +177,7 @@ public void writeTo(StreamOutput out) throws IOException {`
`177`	`177`	`@Override`
`178`	`178`	`public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {`
`179`	`179`	`builder.startObject();`
	`180`	`+ toXContentCommon(builder, params);`
`180`	`181`	`builder.field("stopped", stopped);`
`181`	`182`	`builder.endObject();`
`182`	`183`	`return builder;`