You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by oz...@apache.org on 2016/11/04 11:05:28 UTC
nifi git commit: NIFI-2948 Fix DynamoDB Cached Credentials
Repository: nifi
Updated Branches:
refs/heads/master 0841f14c1 -> 50010fb34
NIFI-2948 Fix DynamoDB Cached Credentials
This closes #1182
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/50010fb3
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/50010fb3
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/50010fb3
Branch: refs/heads/master
Commit: 50010fb34064d9cf622e265ed57c9ab0be39318e
Parents: 0841f14
Author: James Wing <jv...@gmail.com>
Authored: Thu Nov 3 20:24:19 2016 -0700
Committer: Oleg Zhurakousky <ol...@suitcase.io>
Committed: Fri Nov 4 07:04:25 2016 -0400
----------------------------------------------------------------------
.../processors/aws/dynamodb/AbstractDynamoDBProcessor.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/50010fb3/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/dynamodb/AbstractDynamoDBProcessor.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/dynamodb/AbstractDynamoDBProcessor.java b/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/dynamodb/AbstractDynamoDBProcessor.java
index de56e69..e1a31a9 100644
--- a/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/dynamodb/AbstractDynamoDBProcessor.java
+++ b/nifi-nar-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/dynamodb/AbstractDynamoDBProcessor.java
@@ -28,6 +28,7 @@ import java.util.Map;
import java.util.Set;
import org.apache.commons.lang3.StringUtils;
+import org.apache.nifi.annotation.lifecycle.OnStopped;
import org.apache.nifi.components.AllowableValue;
import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.flowfile.FlowFile;
@@ -335,4 +336,9 @@ public abstract class AbstractDynamoDBProcessor extends AbstractAWSCredentialsPr
return isConsistent;
}
+
+ @OnStopped
+ public void onStopped() {
+ this.dynamoDB = null;
+ }
}