Add reason to flow file on error
This closes
@@ -357,6 +357,7 @@ public class PutElasticsearchHttp extends AbstractElasticsearchHttpProcessor {
new Object[]{flowFile, errorReason});
}
flowFile = session.penalize(flowFile);
+ flowFile = session.putAttribute(flowFile, "reason", errorReason);
session.transfer(flowFile, REL_FAILURE);
} else {
