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 <[email protected]>
Authored: Wed Jan 25 15:31:39 2017 +0100
Committer: Matt Gilman <[email protected]>
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);