Я пытаюсь настроить кластер с тремя узлами, используя встроенный zookeeper. Вот мои конфигурации:
zookeeper.properties
* * 1004
server.1=192.168.0.104:2888:3888
server.2=192.168.0.101:2888:3888
server.3=192.168.0.102:2888:3888
state-management.xml
<cluster-provider>
<id>zk-provider</id>
<class>org.apache.nifi.controller.state.providers.zookeeper.ZooKeeperStateProvider</class>
<property name="Connect String">192.168.0.104:2181,192.168.0.101:2181,192.168.0.102: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.zookeeper.connect.string=192.168.0.104:2181,192.168.0.101:2181,192.168.0.102:2181
nifi.cluster.is.node=true
nifi.cluster.node.address=LOCAL_IP
nifi.cluster.node.protocol.port=3030
nifi.web.http.host=192.168.0.101
nifi.web.http.port=8080
nifi.remote.input.host=192.168.0.101
nifi.state.management.embedded.zookeeper.start=true
Когда я запускаю все узлы после выборов, в моих журналах появляется следующая ошибка:
2018-11-09 17:15:17,846 INFO [Reconnect to Cluster] o.a.nifi.controller.StandardFlowService Node disconnected due to Failed to properly handle Reconnection request due to org.apache.nifi.cluster.ConnectionException: Failed to connect node to cluster due to: java.lang.NullPointerException
2018-11-09 17:15:17,846 ERROR [Reconnect to Cluster] o.a.nifi.controller.StandardFlowService Handling reconnection request failed due to: org.apache.nifi.cluster.ConnectionException: Failed to connect node to cluster due to: java.lang.NullPointerException
org.apache.nifi.cluster.ConnectionException: Failed to connect node to cluster due to: java.lang.NullPointerException
at org.apache.nifi.controller.StandardFlowService.loadFromConnectionResponse(StandardFlowService.java:1009)
at org.apache.nifi.controller.StandardFlowService.handleReconnectionRequest(StandardFlowService.java:666)
at org.apache.nifi.controller.StandardFlowService.access$300(StandardFlowService.java:105)
at org.apache.nifi.controller.StandardFlowService$2.run(StandardFlowService.java:415)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.NullPointerException: null
at org.apache.nifi.controller.StandardFlowService.loadFromConnectionResponse(StandardFlowService.java:963)
... 4 common frames omitted
Я уже проверил порты во всех средах (8080, 3030, 2181, 2888, 3888 открыты). Как я могу устранить эту ошибку?
Заранее спасибо за любую помощь.