diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/job/IgnoreDowntime.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/job/IgnoreDowntime.java
index 370bd092f5c..6cbd5c01cf0 100644
--- a/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/job/IgnoreDowntime.java
+++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/job/IgnoreDowntime.java
@@ -39,7 +39,7 @@ public enum IgnoreDowntime implements Writeable {
     public static IgnoreDowntime fromStream(StreamInput in) throws IOException {
         int ordinal = in.readVInt();
         if (ordinal < 0 || ordinal >= values().length) {
-            throw new IOException("Unknown public enum SchedulerStatus {\n ordinal [" + ordinal + "]");
+            throw new IOException("Unknown public enum IgnoreDowntime {\n ordinal [" + ordinal + "]");
         }
         return values()[ordinal];
     }
diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/job/manager/JobManager.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/job/manager/JobManager.java
index 2ee1f1b744e..3e6ba434714 100644
--- a/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/job/manager/JobManager.java
+++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/job/manager/JobManager.java
@@ -201,7 +201,7 @@ public class JobManager extends AbstractComponent {
     }
 
     ClusterState innerPutJob(Job job, boolean overwrite, ClusterState currentState) {
-        PrelertMetadata.Builder builder = createPrelertMetadatBuilder(currentState);
+        PrelertMetadata.Builder builder = createPrelertMetadataBuilder(currentState);
         builder.putJob(job, overwrite);
         return buildNewClusterState(currentState, builder);
     }
@@ -249,7 +249,7 @@ public class JobManager extends AbstractComponent {
     }
 
     ClusterState removeJobFromClusterState(String jobId, ClusterState currentState) {
-        PrelertMetadata.Builder builder = createPrelertMetadatBuilder(currentState);
+        PrelertMetadata.Builder builder = createPrelertMetadataBuilder(currentState);
         builder.removeJob(jobId);
 
         return buildNewClusterState(currentState, builder);
@@ -269,7 +269,7 @@ public class JobManager extends AbstractComponent {
 
             @Override
             public ClusterState execute(ClusterState currentState) throws Exception {
-                PrelertMetadata.Builder builder = createPrelertMetadatBuilder(currentState);
+                PrelertMetadata.Builder builder = createPrelertMetadataBuilder(currentState);
                 builder.updateSchedulerStatus(jobId, newStatus);
                 return buildNewClusterState(currentState, builder);
             }
@@ -399,7 +399,7 @@ public class JobManager extends AbstractComponent {
         jobResultsPersister.commitWrites(jobId);
     }
 
-    private static PrelertMetadata.Builder createPrelertMetadatBuilder(ClusterState currentState) {
+    private static PrelertMetadata.Builder createPrelertMetadataBuilder(ClusterState currentState) {
         PrelertMetadata currentPrelertMetadata = currentState.metaData().custom(PrelertMetadata.TYPE);
         return new PrelertMetadata.Builder(currentPrelertMetadata);
     }