Tom created FLINK-33917: --------------------------- Summary: IllegalArgumentException: hostname can't be null Key: FLINK-33917 URL: https://issues.apache.org/jira/browse/FLINK-33917 Project: Flink Issue Type: Bug Components: Kubernetes Operator Reporter: Tom
In certain scenarios, if the hostname contains certain characters it will throw an exception when it tries to initialize the InetSocketAddress @Override public boolean isJobManagerPortReady(Configuration config) { final URI uri; try (var clusterClient = getClusterClient(config)) { uri = URI.create(clusterClient.getWebInterfaceURL()); } catch (Exception ex) { throw new FlinkRuntimeException(ex); } SocketAddress socketAddress = new InetSocketAddress(uri.getHost(), uri.getPort()); Socket socket = new Socket(); try { socket.connect(socketAddress, 1000); socket.close(); return true; } catch (IOException e) { return false; } } -- This message was sent by Atlassian Jira (v8.20.10#820010)