nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From marka...@apache.org
Subject [nifi] branch master updated: NIFI-6759: When encountering Exception during load-balanced connection communications, after closing socket, return from method rather than continuing loop
Date Wed, 09 Oct 2019 20:06:00 GMT
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 <markap14@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;
                 }
             }
         }


Mime
View raw message