From a232cac6527019fe922c26a69821478f3ac280ca Mon Sep 17 00:00:00 2001
From: Jared Noble <jsnoble1@gmail.com>
Date: Thu, 14 Sep 2017 12:44:23 -0700
Subject: [PATCH] added job_id to analytics data resolves #544

---
 lib/cluster/storage/analytics.js                     | 1 +
 lib/cluster/storage/backends/mappings/analytics.json | 4 ++++
 2 files changed, 5 insertions(+)

diff --git a/lib/cluster/storage/analytics.js b/lib/cluster/storage/analytics.js
index 28bbe391214..e05f007c60b 100644
--- a/lib/cluster/storage/analytics.js
+++ b/lib/cluster/storage/analytics.js
@@ -25,6 +25,7 @@ module.exports = function(context) {
             results.push(backend.bulk({
                 "@timestamp": timestamp,
                 ex_id: job.jobConfig.ex_id,
+                job_id: job.jobConfig.job_id,
                 worker_id: worker_id,
                 slice_id: slice_info.slice_id,
                 slicer_id: slice_info.slicer_id,
diff --git a/lib/cluster/storage/backends/mappings/analytics.json b/lib/cluster/storage/backends/mappings/analytics.json
index 26575f48b65..6758dad15ea 100644
--- a/lib/cluster/storage/backends/mappings/analytics.json
+++ b/lib/cluster/storage/backends/mappings/analytics.json
@@ -14,6 +14,10 @@
                     "type": "string",
                     "index" : "not_analyzed"
                 },
+                "job_id": {
+                    "type": "string",
+                    "index" : "not_analyzed"
+                },
                 "worker_id": {
                     "type": "string",
                     "index" : "not_analyzed"