nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From joew...@apache.org
Subject [2/2] nifi git commit: NIFI-1464 fixed OnScheduled invocation to pass ProcessContext
Date Tue, 15 Mar 2016 17:25:28 GMT
NIFI-1464 fixed OnScheduled invocation to pass ProcessContext

NIFI-1464 removed unused imports

Signed-off-by: joewitt <joewitt@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/cfeebfe7
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/cfeebfe7
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/cfeebfe7

Branch: refs/heads/master
Commit: cfeebfe7c744f4f0f239ea8256f1adfb62ae6049
Parents: a4a7d53
Author: Oleg Zhurakousky <oleg@suitcase.io>
Authored: Tue Mar 15 09:48:29 2016 -0400
Committer: joewitt <joewitt@apache.org>
Committed: Tue Mar 15 12:54:13 2016 -0400

----------------------------------------------------------------------
 .../org/apache/nifi/controller/StandardProcessorNode.java    | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/nifi/blob/cfeebfe7/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardProcessorNode.java
----------------------------------------------------------------------
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 fa7bd30..bb04d90 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;
                                 }
                             }


Mime
View raw message