NIFI-2574 fixed queue swap threshold setting
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/7c99b5e6 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/7c99b5e6 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/7c99b5e6 Branch: refs/heads/master Commit: 7c99b5e638bfbff7a3f69e78e0dbfef105004995 Parents: d963375 Author: joewitt <joew...@apache.org> Authored: Wed Aug 17 09:05:36 2016 -0700 Committer: joewitt <joew...@apache.org> Committed: Wed Aug 17 09:05:36 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/nifi/controller/FlowController.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/7c99b5e6/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java index 8fb2305..b39162a 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java @@ -915,6 +915,7 @@ public class FlowController implements EventAccess, ControllerServiceProvider, R .source(requireNonNull(source)) .destination(destination) .swapManager(swapManager) + .queueSwapThreshold(nifiProperties.getQueueSwapThreshold()) .eventReporter(eventReporter) .resourceClaimManager(resourceClaimManager) .flowFileRepository(flowFileRepository)
