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 2025/01/29 21:10:00 UTC
[jira] [Commented] (NIFI-14197) If Exception thrown from FlowFileFilter, FlowFiles become inaccessible until restart
[ https://issues.apache.org/jira/browse/NIFI-14197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922213#comment-17922213 ]
ASF subversion and git services commented on NIFI-14197:
--------------------------------------------------------
Commit e9e6b1f98b6bbdc1c8b8d99c5be2f67d2da2119c in nifi's branch refs/heads/main from Mark Payne
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=e9e6b1f98b ]
NIFI-14197 Fixed Exception Handling for FlowFileFilter with Queued FlowFiles (#9668)
- Ensure that any FlowFiles that are pulled from the FlowFileQueue during ProcessSession.get(FlowFileFilter) are placed back on the queue if an Exception is thrown by the filter
Signed-off-by: David Handermann <ex...@apache.org>
> If Exception thrown from FlowFileFilter, FlowFiles become inaccessible until restart
> ------------------------------------------------------------------------------------
>
> Key: NIFI-14197
> URL: https://issues.apache.org/jira/browse/NIFI-14197
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Reporter: Mark Payne
> Assignee: Mark Payne
> Priority: Major
> Time Spent: 1h
> Remaining Estimate: 0h
>
> If a Processor provides a {{FlowFileFilter}} to the {{ProcessSession.get(FlowFileFilter)}} method, and the {{FlowFileFilter}} throws an exception, the FlowFile that the filter is evaluating, and all other FlowFiles that it has evaluated, become inaccessible. The queue still shows the data available but the Processor can't get to the FlowFiles. Upon restart of NiFi, the FlowFiles are properly restored and accessible.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)