Repository: nifi Updated Branches: refs/heads/master 8da403ce9 -> 8398ea77b
NIFI-5688: Ensure that when we map our flow to a VersionedProcessGroup that we include the connections' Load Balance Compression flag This closes #3064 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/8398ea77 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/8398ea77 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/8398ea77 Branch: refs/heads/master Commit: 8398ea77bc2cb15068ebba37dd8f7f270befe308 Parents: 8da403c Author: Mark Payne <[email protected]> Authored: Thu Oct 11 14:57:31 2018 -0400 Committer: Matt Gilman <[email protected]> Committed: Thu Oct 11 15:06:06 2018 -0400 ---------------------------------------------------------------------- .../apache/nifi/registry/flow/mapping/NiFiRegistryFlowMapper.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/8398ea77/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/registry/flow/mapping/NiFiRegistryFlowMapper.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/registry/flow/mapping/NiFiRegistryFlowMapper.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/registry/flow/mapping/NiFiRegistryFlowMapper.java index 243e725..521b078 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/registry/flow/mapping/NiFiRegistryFlowMapper.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/registry/flow/mapping/NiFiRegistryFlowMapper.java @@ -250,6 +250,7 @@ public class NiFiRegistryFlowMapper { final FlowFileQueue flowFileQueue = connection.getFlowFileQueue(); versionedConnection.setLoadBalanceStrategy(flowFileQueue.getLoadBalanceStrategy().name()); versionedConnection.setPartitioningAttribute(flowFileQueue.getPartitioningAttribute()); + versionedConnection.setLoadBalanceCompression(flowFileQueue.getLoadBalanceCompression().name()); versionedConnection.setBends(connection.getBendPoints().stream() .map(this::mapPosition)
