Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-2304: If node address is not set, default to localhost, as the admin guide says it should 

This closes #688

Signed-off-by: Koji Kawamura <ijokarumawak@apache.org>
This commit is contained in:
Mark Payne 2016-07-20 12:21:58 -04:00 committed by Koji Kawamura
parent 9a2f8c598e
commit 09840027a3
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/heartbeat/ClusterProtocolHeartbeatMonitor.java
View File

@ -17,8 +17,6 @@
package org.apache.nifi.cluster.coordination.heartbeat;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.nio.charset.StandardCharsets;
import java.util.Collections;
import java.util.HashMap;
@ -91,16 +89,12 @@ public class ClusterProtocolHeartbeatMonitor extends AbstractHeartbeatMonitor im
this.clusterNodesPath = zkClientConfig.resolvePath("cluster/nodes");
String hostname = properties.getProperty(NiFiProperties.CLUSTER_NODE_ADDRESS);
if (hostname == null) {
try {
hostname = InetAddress.getLocalHost().getHostName();
} catch (UnknownHostException e) {
throw new RuntimeException("Unable to determine local hostname and the '" + NiFiProperties.CLUSTER_NODE_ADDRESS + "' property is not set");
}
if (hostname == null || hostname.trim().isEmpty()) {
hostname = "localhost";
}
final String port = properties.getProperty(NiFiProperties.CLUSTER_NODE_PROTOCOL_PORT);
if (port == null) {
if (port == null || port.trim().isEmpty()) {
throw new RuntimeException("Unable to determine which port Cluster Coordinator Protocol is listening on because the '"
+ NiFiProperties.CLUSTER_NODE_PROTOCOL_PORT + "' property is not set");
}