NIFI-2948 Fix DynamoDB Cached Credentials

This closes apache#1182
davyam · Nov 4, 2016 · 50010fb · 50010fb
1 parent 0841f14
commit 50010fb
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...sors/src/main/java/org/apache/nifi/processors/aws/dynamodb/AbstractDynamoDBProcessor.java b/...sors/src/main/java/org/apache/nifi/processors/aws/dynamodb/AbstractDynamoDBProcessor.java
@@ -28,6 +28,7 @@
 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 @@ protected boolean isHashKeyValueConsistent(String hashKeyName, Object hashKeyVal
         return isConsistent;
 
     }
+
+    @OnStopped
+    public void onStopped() {
+        this.dynamoDB = null;
+    }
 }