[
https://issues.apache.org/jira/browse/NIFI-10303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623978#comment-17623978
]
ASF subversion and git services commented on NIFI-10303:
--------------------------------------------------------
Commit b6026f57095d00b1ef63f96eeed03d3fc8eaa861 in nifi's branch
refs/heads/main from Chris Sampson
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=b6026f5709 ]
NIFI-10303 route GetElasticsearch to failure if _id is blank after attribute
evaluation
This closes #6573
Signed-off-by: Mike Thomsen <[email protected]>
> 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)
