Github user MikeThomsen commented on a diff in the pull request: https://github.com/apache/nifi/pull/2601#discussion_r183458469 --- Diff: nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/QueryElasticsearchHttp.java --- @@ -267,30 +267,28 @@ public void setup(ProcessContext context) { @Override public void onPropertyModified(final PropertyDescriptor descriptor, final String oldValue, final String newValue) { + final Set<Relationship> routeQueryInfoRels = new HashSet<>(); + routeQueryInfoRels.add(REL_SUCCESS); + routeQueryInfoRels.add(REL_FAILURE); + routeQueryInfoRels.add(REL_RETRY); + + final Set<Relationship> successRels = new HashSet<>(); + successRels.add(REL_SUCCESS); + successRels.add(REL_FAILURE); + successRels.add(REL_RETRY); + if (ROUTING_QUERY_INFO_STRATEGY.equals(descriptor)) { if (ALWAYS.getValue().equalsIgnoreCase(newValue)) { --- End diff -- Not a deal breaker, but I actually had this location in mind.
---