From bf3eadd8c7efd6f41b90b0ab4e1e0a80c7efad92 Mon Sep 17 00:00:00 2001 From: Mark Payne Date: Fri, 24 Aug 2018 09:55:15 -0400 Subject: [PATCH] NIFI-5551: If session.get() returns null, then return fron onTrigger instead of assuming that the FlowFile is non-null --- .../org/apache/nifi/processors/standard/UpdateCounter.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UpdateCounter.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UpdateCounter.java index 5115817c277c..e8f3bcf1015f 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UpdateCounter.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/UpdateCounter.java @@ -100,6 +100,10 @@ protected List getSupportedPropertyDescriptors() { @Override public void onTrigger(ProcessContext context, ProcessSession session) throws ProcessException { FlowFile flowFile = session.get(); + if (flowFile == null) { + return; + } + session.adjustCounter(context.getProperty(COUNTER_NAME).evaluateAttributeExpressions(flowFile).getValue(), Long.parseLong(context.getProperty(DELTA).evaluateAttributeExpressions(flowFile).getValue()), false