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 <jvw...@gmail.com> Authored: Thu Nov 3 20:24:19 2016 -0700 Committer: Oleg Zhurakousky <o...@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; + } }
