From ea273ab67e271f37cc661696fe319dd1c2ab62b9 Mon Sep 17 00:00:00 2001
From: Martijn van Groningen <martijn.v.groningen@gmail.com>
Date: Fri, 24 Mar 2017 19:36:12 +0100
Subject: [PATCH] [ML] Made fields volatile or final

Original commit: elastic/x-pack-elasticsearch@c9478e2da461228f3cb52fa4bed9416c5a10f4d6
---
 .../ml/job/process/autodetect/NativeAutodetectProcess.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/NativeAutodetectProcess.java b/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/NativeAutodetectProcess.java
index 8527bc8f3cb..234de084161 100644
--- a/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/NativeAutodetectProcess.java
+++ b/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/NativeAutodetectProcess.java
@@ -49,9 +49,9 @@ class NativeAutodetectProcess implements AutodetectProcess {
     private final ZonedDateTime startTime;
     private final int numberOfAnalysisFields;
     private final List<Path> filesToDelete;
-    private Future<?> logTailFuture;
-    private Future<?> stateProcessorFuture;
-    private AutodetectResultsParser resultsParser;
+    private volatile Future<?> logTailFuture;
+    private volatile Future<?> stateProcessorFuture;
+    private final AutodetectResultsParser resultsParser;
 
     NativeAutodetectProcess(String jobId, InputStream logStream, OutputStream processInStream, InputStream processOutStream,
                             int numberOfAnalysisFields, List<Path> filesToDelete, AutodetectResultsParser resultsParser) {