You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2016/12/13 16:30:52 UTC
nifi git commit: NIFI-3192 Adding a check if the FlowFile is null to
UpdateAttribute
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 <JP...@apache.org>
Authored: Tue Dec 13 11:10:25 2016 -0500
Committer: Matt Burgess <ma...@apache.org>
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();