[ 
https://issues.apache.org/jira/browse/NIFI-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492552#comment-17492552
 ] 

davide commented on NIFI-9574:
------------------------------

Hi [~markap14], I have the same problem like Mahieddine.

I have a 3 nodes cluster(as you can see on attached images) with a connection 
with a Load Balance Strategy set to Partition by attribute, sometimes some 
flowfiles get stuck in this connection (see image1). Furthermore we have this 
log error in bulletin board

{{10:56:28 UTC ERROR xxxx-xxx-xx-nifi0.xxxx:8443 }}

{{Failed to receive FlowFiles for Load Balancing due to 
org.apache.nifi.controller.queue.clustered.server.TransactionAbortedException: 
Attempted to receive FlowFiles from Peer xxxx-xxx-xx-nifi2.xxxx for Connection 
with ID 0c20343f-f63d-1ef1-8da0-6d3cb9fc670d but no Connection exists with that 
ID}}
{{10:56:28 UTC ERROR xxxx-xxx-xx-nifi0.xxxx:8443}}

{{{}Failed to communicate with Peer xxxx-xxx-xx-nifi2.xxxx:8443 when load 
balancing data for Connection with ID c12f3c02-9f05-1232-ffff-fffff8d925a9 due 
to java.io.IOException: Failed to decrypt data from Peer 
xxxx-xxx-xx-nifi2.xxxx:8443 because Peer unexpectedly closed 
connection{}}}{{{}{}}}

 

The weird thing is that only some flowfiles are stucked other flowfiles goes 
forward in the flows.

 

How can i fix it? 

Any suggestion?

 

Thank you 

 

!flow.png!!heapUse.png!!activeThread.png!!version.png!!cores.png!

 

>  Failed to decrypt data from Peer
> ---------------------------------
>
>                 Key: NIFI-9574
>                 URL: https://issues.apache.org/jira/browse/NIFI-9574
>             Project: Apache NiFi
>          Issue Type: Bug
>            Reporter: Mahieddine Cherif
>            Priority: Major
>         Attachments: Screenshot 2022-01-14 at 19.21.11.png, Screenshot 
> 2022-01-14 at 19.21.16.png, Screenshot 2022-01-14 at 19.21.36.png, Screenshot 
> 2022-01-14 at 19.21.46.png, activeThread.png, cores.png, flow.png, 
> heapUse.png, version.png
>
>
> After a migration to 1.15.2 it seems like we have almost systematically this 
> error on our cluster all the time 
> {code:java}
> Failed to communicate with Peer 
> nifi-0.nifi-headless.apache-nifi.svc.cluster.local:8443 when load balancing 
> data for Connection with ID b76e7297-e8a0-3b2b-ba30-d338db411301 due to 
> java.io.IOException: Failed to decrypt data from Peer 
> nifi-0.nifi-headless.apache-nifi.svc.cluster.local:8443 because Peer 
> unexpectedly closed connection
> {code}
> Files get stuck in the queue mentioned, it's not always the same, these are 
> simple round robin queues with or without compression. 
> When we recreate the cluster it goes for like some time and then it occurs 
> again and again 
> Is there a particular reason ? 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to