Repository: nifi Updated Branches: refs/heads/master 4baffacc4 -> f34d73e73
NIFI-895 ensuring the session factory is re-set in the onTrigger method in the case where the runner needed to be stopped Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/f34d73e7 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/f34d73e7 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/f34d73e7 Branch: refs/heads/master Commit: f34d73e73e2216c15e0a10df7092287df665a001 Parents: 4baffac Author: Bryan Bende <[email protected]> Authored: Wed Aug 26 11:21:08 2015 -0400 Committer: Bryan Bende <[email protected]> Committed: Wed Aug 26 11:21:08 2015 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/f34d73e7/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java ---------------------------------------------------------------------- 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 70f82cc..600f4b1 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());
