[
https://issues.apache.org/jira/browse/NIFI-13106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pierre Villard resolved NIFI-13106.
-----------------------------------
Resolution: Feedback Received
Apache NiFi 1.x is no longer maintained and no new release is planned on the
1.x release line. Marking as resolved as part of a cleanup operation. Please
open a new one with an updated description if this is still relevant for NiFi
2.x.
> Loadbalance does not handle all cases of ContentNotFound correctly
> ------------------------------------------------------------------
>
> Key: NIFI-13106
> URL: https://issues.apache.org/jira/browse/NIFI-13106
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 1.22.0
> Reporter: saarbs
> Priority: Minor
>
> In cases where the ContentRepositoryFlowFileAccess is able to skip to the
> content but the content is cut in the middle then an EOF exception is thrown
> and not handled accordingly
>
> Log Sample:
> [ERROR] [Load-Balanced Client Thread-5]
> [o.a.n.c.q.c.c.a.n.NioAsyncLoadBalanceClient] Failed to communicate with Peer
> localhost:8080
> java.io.EOFException: Expected
> StandardFlowFileRecord[uuid=848d2364-e7db-4071-a345-b9b3f66d3afc,claim=StandardContentClaim
> [resourceClaim=StandardResourceClaim[id=1714171534814-132572,
> container=default, section=476], offset=0,
> length=1741],offest-0,name=848d2364-e7db-4071-a345-b9b3f66d3afc,size=1741] to
> contain 1741 bytes but the content repository only had 0 bytes for it
> at
> org.apache.nifi.controller.queue.clustered.ContentRepositoryFlowFileAccess$1.ensureNotTruncated(ContentRepositoryFlowFileAccess.java:83)
> at
> org.apache.nifi.controller.queue.clustered.ContentRepositoryFlowFileAccess$1.read(ContentRepositoryFlowFileAccess.java:63)
> at org.apache.nifi.stream.io.StreamUtils.fillBuffer(StreamUtils.java:89)
> at
> org.apache.nifi.controller.queue.clustered.client.async.nio.LoadBalanceSession.getFlowFileContent(LoadBalanceSession.java:298)
> at
> org.apache.nifi.controller.queue.clustered.client.async.nio.LoadBalanceSession.getDataFrame(LoadBalanceSession.java:253)
> at
> org.apache.nifi.controller.queue.clustered.client.async.nio.LoadBalanceSession.communicate(LoadBalanceSession.java:155)
> at
> org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.communicate(NioAsyncLoadBalanceClient.java:265)
> at
> org.apache.nifi.controller.queue.clustered.client.async.nio.NioAsyncLoadBalanceClient.run(NioAsyncLoadBalanceClient.java:81)
> at org.apache.nifi.engine.FlowEngine$2.run(FlowFileEngine.java:110)
> at java.base/java.util.concurrent.Executer$RunnableAdapter.call(Unknown
> Source)
> at java.base/java.util.concurrent.FututeTask.run(Unknown Source)
> at
> java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown
> Source)
> at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
> at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
> Source)
> at java.base/java.lang.Thread.run(Unknown Source)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
