Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-1464 fixed OnScheduled invocation to pass ProcessContext 

NIFI-1464 removed unused imports

Signed-off-by: joewitt <joewitt@apache.org>
This commit is contained in:
Oleg Zhurakousky 2016-03-15 09:48:29 -04:00 committed by joewitt
parent a4a7d53769
commit cfeebfe7c7
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
View File

@ -70,9 +70,7 @@ import org.apache.nifi.processor.ProcessContext;
import org.apache.nifi.processor.ProcessSessionFactory; import org.apache.nifi.processor.ProcessSessionFactory;
import org.apache.nifi.processor.Processor; import org.apache.nifi.processor.Processor;
import org.apache.nifi.processor.Relationship; import org.apache.nifi.processor.Relationship;
import org.apache.nifi.processor.SchedulingContext;
import org.apache.nifi.processor.SimpleProcessLogger; import org.apache.nifi.processor.SimpleProcessLogger;
import org.apache.nifi.processor.StandardSchedulingContext;
import org.apache.nifi.scheduling.SchedulingStrategy; import org.apache.nifi.scheduling.SchedulingStrategy;
import org.apache.nifi.util.FormatUtils; import org.apache.nifi.util.FormatUtils;
import org.apache.nifi.util.NiFiProperties; import org.apache.nifi.util.NiFiProperties;
@ -1245,12 +1243,8 @@ public class StandardProcessorNode extends ProcessorNode implements Connectable
@Override @Override
public Void call() throws Exception { public Void call() throws Exception {
try (final NarCloseable nc = NarCloseable.withNarLoader()) { try (final NarCloseable nc = NarCloseable.withNarLoader()) {
SchedulingContext schedulingContext = new StandardSchedulingContext(processContext,
getControllerServiceProvider(), StandardProcessorNode.this,
processContext.getStateManager());
ReflectionUtils.invokeMethodsWithAnnotations(OnScheduled.class, ReflectionUtils.invokeMethodsWithAnnotations(OnScheduled.class,
org.apache.nifi.processor.annotation.OnScheduled.class, processor, org.apache.nifi.processor.annotation.OnScheduled.class, processor, processContext);
schedulingContext);
return null; return null;
} }
} }