diff --git a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
index 70f82ccc47..600f4b195c 100644
--- a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
+++ b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
@@ -165,6 +165,7 @@ public class ExecuteFlumeSource extends AbstractFlumeProcessor {
             if (old != sessionFactory) {
                 if (runnerRef.get() != null) {
                     stopped();
+                    sessionFactoryRef.set(sessionFactory);
                 }
 
                 runnerRef.set(new EventDrivenSourceRunner());