This is an automated email from the ASF dual-hosted git repository. markap14 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 650c6aa820fca0eb8d35c506c7a2e71ca892370d Author: samhjelmfelt <[email protected]> AuthorDate: Mon May 20 16:07:22 2019 -0700 Small fix after rebase --- .../nifi/stateless/core/StatelessProcessContext.java | 15 +++++++++++++++ .../nifi/stateless/core/StatelessProcessorWrapper.java | 2 +- 2 files changed, 16 insertions(+), 1 deletion(-) diff --git a/nifi-stateless/nifi-stateless-core/src/main/java/org/apache/nifi/stateless/core/StatelessProcessContext.java b/nifi-stateless/nifi-stateless-core/src/main/java/org/apache/nifi/stateless/core/StatelessProcessContext.java index 3766b07..d0b6db7 100644 --- a/nifi-stateless/nifi-stateless-core/src/main/java/org/apache/nifi/stateless/core/StatelessProcessContext.java +++ b/nifi-stateless/nifi-stateless-core/src/main/java/org/apache/nifi/stateless/core/StatelessProcessContext.java @@ -27,6 +27,7 @@ import org.apache.nifi.components.state.StateManager; import org.apache.nifi.controller.ControllerService; import org.apache.nifi.controller.ControllerServiceInitializationContext; import org.apache.nifi.controller.ControllerServiceLookup; +import org.apache.nifi.controller.NodeTypeProvider; import org.apache.nifi.logging.ComponentLog; import org.apache.nifi.processor.Processor; import org.apache.nifi.processor.Relationship; @@ -393,6 +394,20 @@ public class StatelessProcessContext implements SchedulingContext, ControllerSer } @Override + public NodeTypeProvider getNodeTypeProvider() { + return new NodeTypeProvider() { + @Override + public boolean isClustered() { + return false; + } + @Override + public boolean isPrimary() { + return true; + } + }; + } + + @Override public String getName() { return componentName; } diff --git a/nifi-stateless/nifi-stateless-core/src/main/java/org/apache/nifi/stateless/core/StatelessProcessorWrapper.java b/nifi-stateless/nifi-stateless-core/src/main/java/org/apache/nifi/stateless/core/StatelessProcessorWrapper.java index 108b2e2..8ecb171 100644 --- a/nifi-stateless/nifi-stateless-core/src/main/java/org/apache/nifi/stateless/core/StatelessProcessorWrapper.java +++ b/nifi-stateless/nifi-stateless-core/src/main/java/org/apache/nifi/stateless/core/StatelessProcessorWrapper.java @@ -66,7 +66,7 @@ public class StatelessProcessorWrapper extends AbstractStatelessComponent implem private volatile boolean initialized = false; - StatelessProcessorWrapper(final String id, final Processor processor, final StatelessProcessorWrapper parent, final StatelessControllerServiceLookup lookup, final VariableRegistry registry, + public StatelessProcessorWrapper(final String id, final Processor processor, final StatelessProcessorWrapper parent, final StatelessControllerServiceLookup lookup, final VariableRegistry registry, final boolean materializeContent, final ClassLoader classLoader) throws InvocationTargetException, IllegalAccessException { this.processor = processor;
