You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by mc...@apache.org on 2017/01/25 15:26:03 UTC
nifi git commit: NIFI-3393 - replicates cluster/nodes/{id} to cluster
coordinator. This closes #1443
Repository: nifi
Updated Branches:
refs/heads/master e0e6f0bac -> e113511fe
NIFI-3393 - replicates cluster/nodes/{id} to cluster coordinator. This closes #1443
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/e113511f
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/e113511f
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/e113511f
Branch: refs/heads/master
Commit: e113511fef2f408f24b05da28046d8a3de3b228a
Parents: e0e6f0b
Author: Pierre Villard <pi...@gmail.com>
Authored: Wed Jan 25 15:31:39 2017 +0100
Committer: Matt Gilman <ma...@gmail.com>
Committed: Wed Jan 25 10:25:36 2017 -0500
----------------------------------------------------------------------
.../main/java/org/apache/nifi/web/api/ControllerResource.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/e113511f/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ControllerResource.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/ControllerResource.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ControllerResource.java
index 86ca792..1e56dbb 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ControllerResource.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ControllerResource.java
@@ -512,6 +512,10 @@ public class ControllerResource extends ApplicationResource {
throw new IllegalClusterResourceRequestException("Only a node connected to a cluster can process the request.");
}
+ if (isReplicateRequest()) {
+ return replicate(HttpMethod.GET, getClusterCoordinatorNode());
+ }
+
// get the specified relationship
final NodeDTO dto = serviceFacade.getNode(id);