[ 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)