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)
