diff --git a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectCommunicator.java b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectCommunicator.java
index 550742ef04b5a..139eceb09bd02 100644
--- a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectCommunicator.java
+++ b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectCommunicator.java
@@ -170,6 +170,7 @@ public void close() {
                     killProcess(false, false);
                     stateStreamer.cancel();
                 }
+                dataCountsReporter.writeUnreportedCounts();
                 autodetectResultProcessor.awaitCompletion();
             } finally {
                 onFinishHandler.accept(null, true);
@@ -180,7 +181,6 @@ public void close() {
         try {
             future.get();
             autodetectWorkerExecutor.shutdownNow();
-            dataCountsReporter.writeUnreportedCounts();
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
         } catch (ExecutionException e) {