Apply review comments

elastic · Jun 27, 2019 · e8c0116 · e8c0116
1 parent 5a12e3d
commit e8c0116
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ugin/core/src/main/java/org/elasticsearch/xpack/core/ml/datafeed/DatafeedTimingStats.java b/...ugin/core/src/main/java/org/elasticsearch/xpack/core/ml/datafeed/DatafeedTimingStats.java
@@ -57,7 +57,7 @@ public DatafeedTimingStats(String jobId) {
 
     public DatafeedTimingStats(StreamInput in) throws IOException {
         jobId = in.readString();
-        totalSearchTimeMs = in.readOptionalDouble();
+        totalSearchTimeMs = in.readDouble();
     }
 
     public DatafeedTimingStats(DatafeedTimingStats other) {
@@ -79,7 +79,7 @@ public void incrementTotalSearchTimeMs(double totalSearchTimeMs) {
     @Override
     public void writeTo(StreamOutput out) throws IOException {
         out.writeString(jobId);
-        out.writeOptionalDouble(totalSearchTimeMs);
+        out.writeDouble(totalSearchTimeMs);
     }
 
     @Override