diff --git a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/StandardRecordWriter.java b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/StandardRecordWriter.java
index a8c0dd0d7b..b95d80553a 100644
--- a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/StandardRecordWriter.java
+++ b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/StandardRecordWriter.java
@@ -274,8 +274,13 @@ public class StandardRecordWriter implements RecordWriter {
         lock();
         try {
             try {
-                out.flush();
-                out.close();
+                if (out != null) {
+                    try {
+                        out.flush();
+                    } finally {
+                        out.close();
+                    }
+                }
             } finally {
                 rawOutStream.close();