[GitHub] nifi pull request #3010: [WIP] NIFI-5585

[markap14]

Github user markap14 commented on a diff in the pull request:

    https://github.com/apache/nifi/pull/3010#discussion_r219296344
  
    --- Diff: 
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/clustered/SocketLoadBalancedFlowFileQueue.java
 ---
    @@ -204,6 +206,19 @@ public synchronized void setLoadBalanceStrategy(final 
LoadBalanceStrategy strate
             setFlowFilePartitioner(partitioner);
         }
     
    +    @Override
    +    public void decommissionQueue() {
    +        if (clusterCoordinator == null) {
    +            // Not clustered, so don't change partitions
    +            return;
    +        }
    +
    +        // TODO set decommissioned boolean
    --- End diff --
    
    I think the TODO can go


---