From 5414cd50163e4ae7d7b8bae8f3ecb4d00e4123ff Mon Sep 17 00:00:00 2001
From: Mark Payne <markap14@hotmail.com>
Date: Wed, 9 Oct 2019 14:57:11 -0400
Subject: [PATCH] NIFI-6759: When encountering Exception during load-balanced
 connection communications, after closing socket, return from method rather
 than continuing loop

This closes #3800.
---
 .../queue/clustered/server/ConnectionLoadBalanceServer.java      | 1 +
 1 file changed, 1 insertion(+)

diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/clustered/server/ConnectionLoadBalanceServer.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/clustered/server/ConnectionLoadBalanceServer.java
index 49094c5f58..920e08a783 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/clustered/server/ConnectionLoadBalanceServer.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/clustered/server/ConnectionLoadBalanceServer.java
@@ -166,6 +166,7 @@ public class ConnectionLoadBalanceServer {
 
                     logger.error("Failed to communicate with Peer {}", peerDescription, e);
                     eventReporter.reportEvent(Severity.ERROR, "Load Balanced Connection", "Failed to receive FlowFiles for Load Balancing due to " + e);
+                    return;
                 }
             }
         }