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;
}
}
}
|