From cfeebfe7c744f4f0f239ea8256f1adfb62ae6049 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Tue, 15 Mar 2016 09:48:29 -0400 Subject: [PATCH] NIFI-1464 fixed OnScheduled invocation to pass ProcessContext NIFI-1464 removed unused imports Signed-off-by: joewitt --- .../org/apache/nifi/controller/StandardProcessorNode.java | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java index fa7bd30a8a..bb04d90ffb 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java @@ -70,9 +70,7 @@ import org.apache.nifi.processor.ProcessContext; import org.apache.nifi.processor.ProcessSessionFactory; import org.apache.nifi.processor.Processor; import org.apache.nifi.processor.Relationship; -import org.apache.nifi.processor.SchedulingContext; import org.apache.nifi.processor.SimpleProcessLogger; -import org.apache.nifi.processor.StandardSchedulingContext; import org.apache.nifi.scheduling.SchedulingStrategy; import org.apache.nifi.util.FormatUtils; import org.apache.nifi.util.NiFiProperties; @@ -1245,12 +1243,8 @@ public class StandardProcessorNode extends ProcessorNode implements Connectable @Override public Void call() throws Exception { try (final NarCloseable nc = NarCloseable.withNarLoader()) { - SchedulingContext schedulingContext = new StandardSchedulingContext(processContext, - getControllerServiceProvider(), StandardProcessorNode.this, - processContext.getStateManager()); ReflectionUtils.invokeMethodsWithAnnotations(OnScheduled.class, - org.apache.nifi.processor.annotation.OnScheduled.class, processor, - schedulingContext); + org.apache.nifi.processor.annotation.OnScheduled.class, processor, processContext); return null; } }