Repository: incubator-nifi Updated Branches: refs/heads/NIFI-250 ffb4e6b68 -> 6c678bfe6
NIFI-250: - Prevented reading of the node response because when clustered the responses are merged and we need to use the updated entity. Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/6c678bfe Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/6c678bfe Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/6c678bfe Branch: refs/heads/NIFI-250 Commit: 6c678bfe6adf9e15b294523603dbf230d731b3c9 Parents: ffb4e6b Author: Matt Gilman <[email protected]> Authored: Thu Mar 26 10:42:24 2015 -0400 Committer: Matt Gilman <[email protected]> Committed: Thu Mar 26 10:42:24 2015 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/nifi/web/StandardNiFiWebContext.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/6c678bfe/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/StandardNiFiWebContext.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/StandardNiFiWebContext.java b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/StandardNiFiWebContext.java index ef7626d..eaf457e 100644 --- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/StandardNiFiWebContext.java +++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/StandardNiFiWebContext.java @@ -196,7 +196,10 @@ public class StandardNiFiWebContext implements NiFiWebContext { } // return processor - final ProcessorEntity entity = nodeResponse.getClientResponse().getEntity(ProcessorEntity.class); + ProcessorEntity entity = (ProcessorEntity) nodeResponse.getUpdatedEntity(); + if (entity == null) { + entity = nodeResponse.getClientResponse().getEntity(ProcessorEntity.class); + } processor = entity.getProcessor(); } else { processor = serviceFacade.getProcessor(processorId);
