mirror of https://github.com/apache/nifi.git
NIFI-65:
- Addressed issues submitting replays while clustered.
This commit is contained in:
parent
2436b5338e
commit
1a34e75c5b
|
@ -166,7 +166,7 @@ public class ProvenanceResource extends ApplicationResource {
|
||||||
public Response submitReplay(
|
public Response submitReplay(
|
||||||
@Context HttpServletRequest httpServletRequest,
|
@Context HttpServletRequest httpServletRequest,
|
||||||
@FormParam(CLIENT_ID) @DefaultValue(StringUtils.EMPTY) ClientIdParameter clientId,
|
@FormParam(CLIENT_ID) @DefaultValue(StringUtils.EMPTY) ClientIdParameter clientId,
|
||||||
@QueryParam("clusterNodeId") String clusterNodeId,
|
@FormParam("clusterNodeId") String clusterNodeId,
|
||||||
@FormParam("eventId") LongParameter eventId) {
|
@FormParam("eventId") LongParameter eventId) {
|
||||||
|
|
||||||
// ensure the event id is specified
|
// ensure the event id is specified
|
||||||
|
@ -190,7 +190,7 @@ public class ProvenanceResource extends ApplicationResource {
|
||||||
targetNodes.add(targetNode.getNodeId());
|
targetNodes.add(targetNode.getNodeId());
|
||||||
|
|
||||||
// replicate the request to the specific node
|
// replicate the request to the specific node
|
||||||
return clusterManager.applyRequest(HttpMethod.GET, getAbsolutePath(), getRequestParameters(true), getHeaders(), targetNodes).getResponse();
|
return clusterManager.applyRequest(HttpMethod.POST, getAbsolutePath(), getRequestParameters(true), getHeaders(), targetNodes).getResponse();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue