Merge 7a3971a into f9a15d3

eclipse-kapua · Apr 23, 2021 · c50502a · c50502a
2 parents f9a15d3 + 7a3971a
commit c50502a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...ain/java/org/eclipse/kapua/service/elasticsearch/client/rest/RestElasticsearchClient.java b/...ain/java/org/eclipse/kapua/service/elasticsearch/client/rest/RestElasticsearchClient.java
@@ -19,6 +19,7 @@
 import com.fasterxml.jackson.databind.SerializationFeature;
 import com.fasterxml.jackson.databind.node.ArrayNode;
 import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.http.ParseException;
 import org.apache.http.util.EntityUtils;
 import org.eclipse.kapua.commons.metric.MetricServiceFactory;
@@ -240,6 +241,10 @@ public BulkUpdateResponse upsert(BulkUpdateRequest bulkUpdateRequest) throws Cli
                         if (failureNode != null) {
                             failureMessage = failureNode.asText();
                         }
+                        String reason = jsonNode.at("/error/reason").asText();
+                        if (StringUtils.isNotBlank(reason)) {
+                            failureMessage = reason;
+                        }
                         bulkResponse.add(new UpdateResponse(metricId, new TypeDescriptor(indexName, typeName), failureMessage));
                         LOG.info("Upsert failed [{}, {}, {}]", indexName, typeName, failureMessage);
                         continue;