From f34d73e73e2216c15e0a10df7092287df665a001 Mon Sep 17 00:00:00 2001
From: Bryan Bende <bbende@apache.org>
Date: Wed, 26 Aug 2015 11:21:08 -0400
Subject: [PATCH] NIFI-895 ensuring the session factory is re-set in the
 onTrigger method in the case where the runner needed to be stopped

---
 .../org/apache/nifi/processors/flume/ExecuteFlumeSource.java     | 1 +
 1 file changed, 1 insertion(+)

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());