Team, Need help in setting up NiFi Cluster with 3 nodes, while i am trying to setup with below parameters, i am getting error. Please suggest where i am going wrong   NiFi Version: nifi-2.2.0 state-management.xml <cluster-provider> <id>cluster-provider</id> <class>org.apache.nifi.controller.state.providers.raft.RaftStateProvider</class> <property name="Connect String">Host1_IPAddress:2181,Host2_IPAddress:2181,Host3_IPAddress:2181</property> <property name="Root Node">/nifi</property> <property name="Session Timeout">10 seconds</property> <property name="Access Control">Open</property> </cluster-provider> NiFi Properties: nifi.cluster.is.node=true nifi.cluster.node.address=Host1_IPAddress nifi.cluster.node.protocol.port=9999 nifi.cluster.flow.election.max.candidates=3 nifi.sensitive.props.key=KeyValue nifi.state.management.provider.cluster=cluster-provider nifi.web.https.host=localhost nifi.web.https.port=8444 Error: Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.nifi.components.state.StateManagerProvider]: Factory method 'stateManagerProvider' threw exception with message: Cannot create CLUSTER Provider of type org.apache.nifi.controller.state.providers.raft.RaftStateProvider at org.springframework.beans.factory.support.SimpleInstantiationStrategy.lambda$instantiate$0(SimpleInstantiationStrategy.java:199) at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiateWithFactoryMethod(SimpleInstantiationStrategy.java:88) at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:168) at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:653) ... 65 common frames omitted Caused by: java.lang.RuntimeException: Cannot create CLUSTER Provider of type org.apache.nifi.controller.state.providers.raft.RaftStateProvider at org.apache.nifi.controller.state.manager.StandardStateManagerProvider.createStateProvider(StandardStateManagerProvider.java:289) at org.apache.nifi.controller.state.manager.StandardStateManagerProvider.createClusteredStateProvider(StandardStateManagerProvider.java:156) at org.apache.nifi.controller.state.manager.StandardStateManagerProvider.create(StandardStateManagerProvider.java:122) at org.apache.nifi.framework.configuration.ManagerConfiguration.stateManagerProvider(ManagerConfiguration.java:83) at org.apache.nifi.framework.configuration.ManagerConfiguration$$SpringCGLIB$$0.CGLIB$stateManagerProvider$2(<generated>) at org.apache.nifi.framework.configuration.ManagerConfiguration$$SpringCGLIB$$FastClass$$1.invoke(<generated>) at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:258) at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:348) at org.apache.nifi.framework.configuration.ManagerConfiguration$$SpringCGLIB$$0.stateManagerProvider(<generated>) at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103) at java.base/java.lang.reflect.Method.invoke(Method.java:580) at org.springframework.beans.factory.support.SimpleInstantiationStrategy.lambda$instantiate$0(SimpleInstantiationStrategy.java:171) ... 68 common frames omitted Caused by: java.lang.IllegalStateException: The specified class 'org.apache.nifi.controller.state.providers.raft.RaftStateProvider' is not known to this nifi. at org.apache.nifi.controller.state.manager.StandardStateManagerProvider.instantiateStateProvider(StandardStateManagerProvider.java:389) at org.apache.nifi.controller.state.manager.StandardStateManagerProvider.createStateProvider(StandardStateManagerProvider.java:287) ... 79 common frames omitted ... View more

I have a processor group PG with below processors for example A -> B -> C       D-> E->F Processor C  (Execute Stream Command) runs a Python code using multi threads  - generates files Processor D ( List File) will list the files generated by above processor C and transforms and processes  to F (PutElasticSearchJSON) Have a requirement to run this  processor group for one date at a time, start execution for next date only after capturing the status of previous date execution status (success/failure) I am ok  using Python/Shell Script. Guide me how can this be achieved. ... View more