added job_id to analytics data resolves #544

terascope · Sep 14, 2017 · a232cac · a232cac
1 parent d5397d6
commit a232cac
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git 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
@@ -14,6 +14,10 @@
                     "type": "string",
                     "index" : "not_analyzed"
                 },
+                "job_id": {
+                    "type": "string",
+                    "index" : "not_analyzed"
+                },
                 "worker_id": {
                     "type": "string",
                     "index" : "not_analyzed"