Repository: nifi Updated Branches: refs/heads/master 868795cda -> 266bd80bd
NIFI-3192 Adding a check if the FlowFile is null to UpdateAttribute This closes #1325 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/266bd80b Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/266bd80b Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/266bd80b Branch: refs/heads/master Commit: 266bd80bde15abb72e316c2386b4664c7c58a1e6 Parents: 868795c Author: jpercivall <[email protected]> Authored: Tue Dec 13 11:10:25 2016 -0500 Committer: Matt Burgess <[email protected]> Committed: Tue Dec 13 11:30:24 2016 -0500 ---------------------------------------------------------------------- .../org/apache/nifi/processors/attributes/UpdateAttribute.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/266bd80b/nifi-nar-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java b/nifi-nar-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java index 22e558b..86f523a 100644 --- a/nifi-nar-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java +++ b/nifi-nar-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java @@ -393,6 +393,9 @@ public class UpdateAttribute extends AbstractProcessor implements Searchable { final Criteria criteria = criteriaCache.get(); FlowFile flowFile = session.get(); + if (flowFile == null) { + return; + } final Map<PropertyDescriptor, String> properties = context.getProperties();
