Repository: nifi Updated Branches: refs/heads/master ce5330330 -> e7e349631
NIFI-2021: Fixed infinite replicated recursion. This closes #597 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/e7e34963 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/e7e34963 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/e7e34963 Branch: refs/heads/master Commit: e7e349631f2805662e418a3d72ab335d1211807d Parents: ce53303 Author: Mark Payne <[email protected]> Authored: Thu Jun 30 11:35:09 2016 -0400 Committer: Matt Gilman <[email protected]> Committed: Fri Jul 1 16:42:10 2016 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/web/api/SystemDiagnosticsResource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/e7e34963/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/SystemDiagnosticsResource.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/SystemDiagnosticsResource.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/SystemDiagnosticsResource.java index 8d6229f..cbe6cf7 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/SystemDiagnosticsResource.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/SystemDiagnosticsResource.java @@ -122,7 +122,7 @@ public class SystemDiagnosticsResource extends ApplicationResource { throw new IllegalArgumentException("Nodewise requests cannot be directed at a specific node."); } - if (isConnectedToCluster()) { + if (isReplicateRequest()) { // determine where this request should be sent if (clusterNodeId == null) { final NodeResponse nodeResponse = getRequestReplicator().replicate(HttpMethod.GET, getAbsolutePath(), getRequestParameters(true), getHeaders()).awaitMergedResponse();
