From 7a3de9e9abbd044a9daf891f03247d60fc20c280 Mon Sep 17 00:00:00 2001 From: nitishgoyal13 Date: Mon, 3 Jul 2017 15:59:49 +0530 Subject: [PATCH] ES 5 Migration routing fix --- src/main/java/org/elasticsearch/action/index/IndexRequest.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/main/java/org/elasticsearch/action/index/IndexRequest.java b/src/main/java/org/elasticsearch/action/index/IndexRequest.java index eba135179410d..bda6ae5ea46e0 100644 --- a/src/main/java/org/elasticsearch/action/index/IndexRequest.java +++ b/src/main/java/org/elasticsearch/action/index/IndexRequest.java @@ -779,6 +779,9 @@ public HttpEntity getBulkEntity() throws IOException { if (Strings.hasLength(parent)) { actionMetadata.put("parent", parent); } + if (Strings.hasLength(routing)) { + actionMetadata.put("routing", routing); + } payload.put(opType.name().toLowerCase(Locale.ROOT), actionMetadata); String json = XContentHelper.convertToJson(payload, false);