You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2019/10/09 20:07:00 UTC
[jira] [Commented] (NIFI-6759) If Load-Balanced Connections
encounter IOException, it will loop indefinitely, logging errors instead of
closing the connection and moving on
[ https://issues.apache.org/jira/browse/NIFI-6759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947960#comment-16947960 ]
ASF subversion and git services commented on NIFI-6759:
-------------------------------------------------------
Commit 5414cd50163e4ae7d7b8bae8f3ecb4d00e4123ff in nifi's branch refs/heads/master from Mark Payne
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=5414cd5 ]
NIFI-6759: When encountering Exception during load-balanced connection communications, after closing socket, return from method rather than continuing loop
This closes #3800.
> If Load-Balanced Connections encounter IOException, it will loop indefinitely, logging errors instead of closing the connection and moving on
> ----------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: NIFI-6759
> URL: https://issues.apache.org/jira/browse/NIFI-6759
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 1.10.0
> Reporter: Mark Payne
> Assignee: Mark Payne
> Priority: Blocker
> Fix For: 1.10.0
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> I encountered an Exception when communicating between two nodes using load-balanced connections. Within 2 minutes, I had geneated 2.5 GB of error logs, all of the pattern:
> {code:java}
> 2019-10-09 14:36:35,091 ERROR [Load-Balance Server Thread-17] o.a.n.c.q.c.s.ConnectionLoadBalanceServer Failed to communicate with Peer localhost/127.0.0.1:61671
> java.net.SocketException: Socket is closed
> at sun.security.ssl.SSLSocketImpl.checkEOF(SSLSocketImpl.java:1532)
> at sun.security.ssl.AppInputStream.read(AppInputStream.java:95)
> at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
> at java.io.BufferedInputStream.read(BufferedInputStream.java:265)
> at org.apache.nifi.controller.queue.clustered.server.StandardLoadBalanceProtocol.negotiateProtocolVersion(StandardLoadBalanceProtocol.java:143)
> at org.apache.nifi.controller.queue.clustered.server.StandardLoadBalanceProtocol.receiveFlowFiles(StandardLoadBalanceProtocol.java:122)
> at org.apache.nifi.controller.queue.clustered.server.ConnectionLoadBalanceServer$CommunicateAction.run(ConnectionLoadBalanceServer.java:152)
> at java.lang.Thread.run(Thread.java:745)
> 2019-10-09 14:36:35,091 ERROR [Load-Balance Server Thread-5] o.a.n.c.q.c.s.ConnectionLoadBalanceServer Failed to communicate with Peer localhost/127.0.0.1:61644
> java.net.SocketException: Socket is closed
> at sun.security.ssl.SSLSocketImpl.checkEOF(SSLSocketImpl.java:1532)
> at sun.security.ssl.AppInputStream.read(AppInputStream.java:95)
> at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
> at java.io.BufferedInputStream.read(BufferedInputStream.java:265)
> at org.apache.nifi.controller.queue.clustered.server.StandardLoadBalanceProtocol.negotiateProtocolVersion(StandardLoadBalanceProtocol.java:143)
> at org.apache.nifi.controller.queue.clustered.server.StandardLoadBalanceProtocol.receiveFlowFiles(StandardLoadBalanceProtocol.java:122)
> at org.apache.nifi.controller.queue.clustered.server.ConnectionLoadBalanceServer$CommunicateAction.run(ConnectionLoadBalanceServer.java:152)
> at java.lang.Thread.run(Thread.java:745)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)