diff --git a/flink-core/src/main/java/org/apache/flink/api/common/io/LocatableInputSplitAssigner.java b/flink-core/src/main/java/org/apache/flink/api/common/io/LocatableInputSplitAssigner.java index 47504256e7507dbccdbc0cbe629ab6be0e4063d6..2f8c2409cae0395ad9d60aad061df37d221608fe 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/io/LocatableInputSplitAssigner.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/io/LocatableInputSplitAssigner.java @@ -180,8 +180,7 @@ public final class LocatableInputSplitAssigner implements InputSplitAssigner { return false; } for (String h : hosts) { - final String hadoopHost = NetUtils.getHostnameFromFQDN(h.toLowerCase()); - if (h != null && hadoopHost.toLowerCase().equals(flinkHost)) { + if (h != null && NetUtils.getHostnameFromFQDN(h.toLowerCase()).equals(flinkHost)) { return true; } } diff --git a/flink-core/src/main/java/org/apache/flink/util/NetUtils.java b/flink-core/src/main/java/org/apache/flink/util/NetUtils.java index ead61ba6ad8128b6fb2437d21e9beda7c8434369..d2fcab847b3e87da27e0145627ac55ae4e787e35 100644 --- a/flink-core/src/main/java/org/apache/flink/util/NetUtils.java +++ b/flink-core/src/main/java/org/apache/flink/util/NetUtils.java @@ -26,6 +26,9 @@ public class NetUtils { * @return */ public static String getHostnameFromFQDN(String fqdn) { + if(fqdn == null) { + throw new IllegalArgumentException("Input string is null (fqdn)"); + } int dotPos = fqdn.indexOf('.'); if(dotPos == -1) { return fqdn; diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/instance/InstanceConnectionInfo.java b/flink-runtime/src/main/java/org/apache/flink/runtime/instance/InstanceConnectionInfo.java index bb4171f53fcc030afae1a2b36df88c3ba218294e..9a7f930bc99e874a04f634b6824d58f2a8cb1134 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/instance/InstanceConnectionInfo.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/instance/InstanceConnectionInfo.java @@ -63,7 +63,13 @@ public class InstanceConnectionInfo implements IOReadableWritable, Comparable