[jira] [Assigned] (NIFI-10303) GetElasticsearch processor invokes elasticsearch GET api without an identifier when flow file is null

["Chris Sampson (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/NIFI-10303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chris Sampson reassigned NIFI-10303:
------------------------------------

    Assignee: Chris Sampson

> GetElasticsearch processor invokes elasticsearch GET api without an identifier when flow file is null
> -----------------------------------------------------------------------------------------------------
>
>                 Key: NIFI-10303
>                 URL: https://issues.apache.org/jira/browse/NIFI-10303
>             Project: Apache NiFi
>          Issue Type: Bug
>    Affects Versions: 1.16.3
>            Reporter: Vijaya Gorla
>            Assignee: Chris Sampson
>            Priority: Major
>              Labels: elasticsearch
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> When GetElasticsearch processor has an incoming connection, and the document id is an expression, this results in expression evaluating to null when the processor runs without a flow file. This in turn results in elasticsearch GET api being invoked without an ID and elastic throwing an error.
> Also noticed that other processors handle this scenario by short-circuiting at the beginning of onTrigger method
> {code:java}
>         FlowFile input = null;
>         if (context.hasIncomingConnection()) {
>             input = session.get();
>             // If we have no FlowFile, and all incoming connections are self-loops then we can continue on.
>             // However, if we have no FlowFile and we have connections coming from other Processors, then
>             // we know that we should run only if we have a FlowFile.
>             if (input == null && context.hasNonLoopConnection()) {
>                 return;
>             }
>         }
> {code}
> However GetElasticsearch  does not.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)