无法让NiFi在群集中工作

Question

根据我读过的所有示例，我认为将NiFi设置为集群会很容易。显然我不能让它工作。我使用的是NiFi 1.5。我只有两台主机，并假装有第三台主机，但NiFi并没有作为集群启动。这些是我对配置文件所做的更改。state-management.xml文件

<cluster-provider>
    <id>zk-provider</id>
    <class>org.apache.nifi.controller.state.providers.zookeeper.ZooKeeperStateProvider</class>
    <property name="Connect String">etl-1:2181,etl-2:2181,etl-3:2181</property>
    <property name="Root Node">/ssd/nifi-1.5.0</property>
    <property name="Session Timeout">10 seconds</property>
    <property name="Access Control">Open</property>
</cluster-provider>

zookeeper.properities文件

dataDir=./state/zookeeper   
server.1=etl-1:2888:3888
server.2=etl-2:2888:3888
server.3=etl-3:2888:3888

nifi.properties文件

nifi.zookeeper.connect.string=etl-1:2181,etl-2:2181,etl-3:2181
nifi.zookeeper.root.node=/ssd/nifi-1.5.0
nifi.cluster.is.node=yes
nifi.cluster.node.address=etl-2  (this is set to etl-1 on the other node)
nifi.state.management.embedded.zookeeper.start=true

nifi@etl-2 zookeeper$ cat /ssd/nifi-1.5.0/state/zookeeper/myid 2 nifi@etl-1日志$ cat /ssd/nifi-1.5.0/state/zookeeper/myid 1

我已经更新了logback.xml以进行调试，但是有太多的消息，我似乎找不到哪里出了问题。我最好的猜测是zookeeper在本地而不是集群中启动。

ls -l /ssd/nifi-1.5.0/state/
total 4
drwxrwxr-x. 18 nifi nifi 4096 Feb 23 18:49 local
drwxrwxr-x.  2 nifi nifi   18 Feb 23 15:26 zookeeper

Answer 1

我找到问题了。我用nifi.cluster.is.node=yes代替了nifi.cluster.is.node=true。

Answer 2

我尝试在Windows 10上将Nifi作为3节点群集运行，并在所有3个conf文件中设置了如上所述的相同属性，但仍然无法将nifi作为3节点群集启动。下面是对我的文件所做的设置

state-management.xml文件

<cluster-provider>
    <id>zk-provider</id>
    <class>org.apache.nifi.controller.state.providers.zookeeper.ZooKeeperStateProvider</class>
    <property name="Connect String">node1:2181,node2:2181,node3:2181</property>
    <property name="Root Node">/nifi</property>
    <property name="Session Timeout">10 seconds</property>
    <property name="Access Control">Open</property>
</cluster-provider>

zookeper属性

dataDir=./state/zookeeper
autopurge.snapRetainCount=30
server.1=node1:2888:3888
server.2=node2:2888:3888
server.3=node3:2888:3888

nifi属性：

nifi.web.http.host=node1
nifi.web.http.port=8080
nifi.cluster.is.node=true
nifi.cluster.node.address=node1
nifi.cluster.node.protocol.port=11122
nifi.zookeeper.connect.string=node1:2181,node2:2181,node3:2181
nifi.zookeeper.root.node=/nifi

在其他两个否中，主机名分别放在

但是当我启动节点时，它显示以下错误C:\nifi-1.11.0-bin\Node1\bin>run-nifi.bat

2020-02-11 20:29:20,237信息主org.apache.nifi.bootstrap.Command启动Apache NiFi...

2020-02-11 20:29:20,238 INFO主org.apache.nifi.bootstrap.Command工作目录: C:\NIFI-1~1.0-B\Node1

2020-02-11 20:29:20,239 INFO主命令:C：\ org.apache.nifi.bootstrap.Command Files\Java\jdk1.8.0_241\bin\java.exe -classpath -classpathC:\NIFI-1~1.0-B\Node1.\lib\jetty-schemas-3.1.jar;C:\NIFI-1~1.0-B\Node1.\lib\jul-to-slf4j-1.7.26.jar;C:\NIFI-1~1.0-B\Node1.\lib\log4j-over-slf4j-1.7.26.jar;C:\NIFI-1~1.0-B\Node1.\lib\logback-classic-1.2.3.jar；C:\NIFI-1~1.0-B\Node1.\lib\logback-core-1.2.3.jar;C:\NIFI-1~1.0-B\Node1.\lib\nifi-api-1.11.0.jar;C:\NIFI-1~1.0-B\Node1.\lib\nifi-framework-api-1.11.0.jar;C:\NIFI-1~1.0-B\Node1.\lib\nifi-nar-utils-1.11.0.jar；C:\NIFI-1~1.0-B\Node1.\lib\nifi-properties-1.11.0.jar;C:\NIFI-1~1.0-B\Node1.\lib\nifi-runtime-1.11.0.jar；C:\NIFI-1~1.0-B\Node1.\lib\slf4j-api-1.7.26.jar -Dorg.apache.jasper.compiler.disablejsr199=true文件安全-Djavax.security.auth.useSubjectCredsOnly=true -Djava.security.egd= -Djava.protocol.handler.pkgs=sun.net.www.protocol -Dnifi.properties.file.path=C:\NIFI-1~1.0-B\Node1.：/ -Xmx512m / -Xms512m -Dsun.net.http.allowRestrictedHeaders=true -Djava.net.preferIPv4Stack=true -Djava.awt.headless=true -Dzookeeper.admin.enableServer=false urandom-Dorg.apache.nifi.bootstrap.config.log.dir=C:\NIFI-1~1.0-B\Node1\bin..\logs org.apache.nifi.NiFi的\conf\nifi.properties -Dnifi.bootstrap.listen.port=53535 -Dapp=NiFi

2020-02-11 20:29:20,554 WARN main org.apache.nifi.bootstrap.Command设置权限失败，因此只有所有者才能读取pid文件C:\NIFI-1~1.0-B\Node1\bin..\run\nifi.pid；这可能允许其他人访问与NiFi通信所需的密钥。应更改权限，以便只有所有者可以读取此文件

2020-02-11 20:29:20,561 WARN main org.apache.nifi.bootstrap.Command无法设置权限，因此只有所有者可以读取状态文件C:\NIFI-1~1.0-B\Node1\bin..\run\nifi.status；这可能允许其他人访问与NiFi通信所需的密钥。应更改权限，以便只有所有者可以读取此文件

2020-02-11 20:29:20,573 INFO main org.apache.nifi.bootstrap.Command已启动Apache NiFi，进程ID为4284

C:\nifi-1.11.0-bin\Node1\bin>status-nifi.bat

20:31:57.265主调试org.apache.nifi.bootstrap.NotificationServiceManager -找到0个服务元素

20:31:57.271主信息org.apache.nifi.bootstrap.NotificationServiceManager -已成功加载以下0个服务：[]

20:31:57.272 main INFO org.apache.nifi.bootstrap.RunNiFi -为通知类型NIFI_STARTED注册无通知服务

20:31:57.273 main INFO org.apache.nifi.bootstrap.RunNiFi -为通知类型NIFI_STOPPED注册无通知服务

20:31:57.274 main INFO org.apache.nifi.bootstrap.RunNiFi -为通知类型NIFI_DIED注册无通知服务

20:31:57.277主调试org.apache.nifi.bootstrap.Command -状态文件: C:\NIFI-1~1.0-B\Node1\bin..\run\nifi.status

20:31:57.278主调试org.apache.nifi.bootstrap.Command -状态文件: C:\NIFI-1~1.0-B\Node1\bin..\run\nifi.status

20:31:57.279主调试org.apache.nifi.bootstrap.Command -属性：{pid=4284，port=53536}

20:31:57.280主调试org.apache.nifi.bootstrap.Command - Pinging 53536

20:31:58.343主调试org.apache.nifi.bootstrap.Command - PID为4284的进程未运行

20:31:58.345 main INFO org.apache.nifi.bootstrap.Command - Apache NiFi未运行