NIFI-5688: Ensure that when we map our flow to a VersionedProcessGrou…

…p that we include the connections' Load Balance Compression flag This closes apache#3064
brandonJY · Oct 11, 2018 · 8398ea7 · 8398ea7
1 parent 8da403c
commit 8398ea7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...work-core/src/main/java/org/apache/nifi/registry/flow/mapping/NiFiRegistryFlowMapper.java b/...work-core/src/main/java/org/apache/nifi/registry/flow/mapping/NiFiRegistryFlowMapper.java
@@ -250,6 +250,7 @@ public VersionedConnection mapConnection(final Connection connection) {
         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)