[nifi] branch master updated: NIFI-6759: When encountering Exception during load-balanced connection communications, after closing socket, return from method rather than continuing loop

[markap14]

This is an automated email from the ASF dual-hosted git repository.

markap14 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/master by this push:
     new 5414cd5  NIFI-6759: When encountering Exception during load-balanced 
connection communications, after closing socket, return from method rather than 
continuing loop
5414cd5 is described below

commit 5414cd50163e4ae7d7b8bae8f3ecb4d00e4123ff
Author: Mark Payne <marka...@hotmail.com>
AuthorDate: Wed Oct 9 14:57:11 2019 -0400

    NIFI-6759: When encountering Exception during load-balanced connection 
communications, after closing socket, return from method rather than continuing 
loop
    
    This closes #3800.
---
 .../controller/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 49094c5..920e08a 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;
                 }
             }
         }