Repository: nifi Updated Branches: refs/heads/0.x ee8b2aaaa -> 663a03541 refs/heads/master 1bd2cf0d0 -> d6674fbb8
NIFI-1898 Fixed Flume processor @OnScheduled methods to accept ProcessContext This closes #455. Signed-off-by: Aldrin Piri <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/663a0354 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/663a0354 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/663a0354 Branch: refs/heads/0.x Commit: 663a03541e8d974e23ecbfb465a3aa511678b4ea Parents: ee8b2aa Author: Oleg Zhurakousky <[email protected]> Authored: Thu May 19 10:10:21 2016 -0400 Committer: Aldrin Piri <[email protected]> Committed: Thu May 19 16:07:41 2016 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java | 3 +-- .../java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java | 3 +-- 2 files changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/663a0354/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java index f93b215..e40608d 100644 --- a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java +++ b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java @@ -35,7 +35,6 @@ import org.apache.nifi.processor.ProcessContext; import org.apache.nifi.processor.ProcessSession; import org.apache.nifi.processor.ProcessorInitializationContext; import org.apache.nifi.processor.Relationship; -import org.apache.nifi.processor.SchedulingContext; import org.apache.nifi.processor.exception.ProcessException; import org.apache.nifi.processor.util.StandardValidators; @@ -107,7 +106,7 @@ public class ExecuteFlumeSink extends AbstractFlumeProcessor { } @OnScheduled - public void onScheduled(final SchedulingContext context) { + public void onScheduled(final ProcessContext context) { try { channel = new NifiSinkSessionChannel(SUCCESS, FAILURE); channel.start(); http://git-wip-us.apache.org/repos/asf/nifi/blob/663a0354/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 3aad6b7..3ef72ff 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 @@ -41,7 +41,6 @@ import org.apache.nifi.processor.ProcessSession; import org.apache.nifi.processor.ProcessSessionFactory; import org.apache.nifi.processor.ProcessorInitializationContext; import org.apache.nifi.processor.Relationship; -import org.apache.nifi.processor.SchedulingContext; import org.apache.nifi.processor.exception.ProcessException; import org.apache.nifi.processor.util.StandardValidators; @@ -117,7 +116,7 @@ public class ExecuteFlumeSource extends AbstractFlumeProcessor { } @OnScheduled - public void onScheduled(final SchedulingContext context) { + public void onScheduled(final ProcessContext context) { try { source = SOURCE_FACTORY.create( context.getProperty(SOURCE_NAME).getValue(),
