Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-16 15:06:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-1898 Fixed Flume processor @OnScheduled methods to accept ProcessContext

Browse Source 
This closes #455.

Signed-off-by: Aldrin Piri <aldrin@apache.org>
This commit is contained in:
Oleg Zhurakousky 2016-05-19 10:10:21 -04:00 committed by Aldrin Piri
parent 1bd2cf0d09
commit d6674fbb8e
2 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSink.java
View File

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

3
nifi-nar-bundles/nifi-flume-bundle/nifi-flume-processors/src/main/java/org/apache/nifi/processors/flume/ExecuteFlumeSource.java
View File

@ -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(),