You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2019/05/21 15:48:09 UTC
[nifi] 05/06: Small fix after rebase
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 <sa...@yahoo.com>
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;