From 2d9fd0ed1691c6e14d04a7ffd5d961a4455c6bcb Mon Sep 17 00:00:00 2001
From: David Kyle <david.kyle@elastic.co>
Date: Tue, 25 Apr 2017 16:04:52 +0100
Subject: [PATCH] [ML] Only audit job creation after it was successful
 (elastic/x-pack-elasticsearch#1198)

Original commit: elastic/x-pack-elasticsearch@37af6cbf693ef8ffe9c26b163ffa3578afdcf85e
---
 .../main/java/org/elasticsearch/xpack/ml/job/JobManager.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plugin/src/main/java/org/elasticsearch/xpack/ml/job/JobManager.java b/plugin/src/main/java/org/elasticsearch/xpack/ml/job/JobManager.java
index 89c27afe03f..92842a31f33 100644
--- a/plugin/src/main/java/org/elasticsearch/xpack/ml/job/JobManager.java
+++ b/plugin/src/main/java/org/elasticsearch/xpack/ml/job/JobManager.java
@@ -169,12 +169,12 @@ public class JobManager extends AbstractComponent {
         jobProvider.createJobResultIndex(job, state, new ActionListener<Boolean>() {
             @Override
             public void onResponse(Boolean indicesCreated) {
-                auditor.info(job.getId(), Messages.getMessage(Messages.JOB_AUDIT_CREATED));
 
                 clusterService.submitStateUpdateTask("put-job-" + job.getId(),
                         new AckedClusterStateUpdateTask<PutJobAction.Response>(request, actionListener) {
                             @Override
                             protected PutJobAction.Response newResponse(boolean acknowledged) {
+                                auditor.info(job.getId(), Messages.getMessage(Messages.JOB_AUDIT_CREATED));
                                 return new PutJobAction.Response(acknowledged, job);
                             }