[
https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26356:
---------------------------
Description:
The clusterClient is built as below. The config is mixed up with the
FlinkDeploymentSpec and local default config.
{code:java}
final int port = config.getInteger(RestOptions.PORT);
final String host =
config.getString(
RestOptions.ADDRESS, String.format("%s-rest.%s", clusterId,
namespace));
final String restServerAddress = String.format("http://%s:%s";, host, port);
{code}
But the {{RestOptions.ADDRESS}} is generated at the entrypoint when the HA is
enabled, so the option can not obtain from the FlinkDeploymentSpec.
Furthermore, the default rest url is not suitable for all the service type. I
think we should extract the rest endpoint from the Flink external service.
was:
The clusterClient is built as below. The config is mixed up with the
FlinkDeploymentSpec and local default config.
{code:java}
final int port = config.getInteger(RestOptions.PORT);
final String host =
config.getString(
RestOptions.ADDRESS, String.format("%s-rest.%s", clusterId,
namespace));
final String restServerAddress = String.format("http://%s:%s";, host, port);
{code}
But the {{RestOptions.ADDRESS}} is generated at the entrypoint when the HA is
enabled, so the option can not obtain from the FlinkDeploymentSpec.
Furthermore, the default rest url is not suitable for all the service type. I
think we should extract the rest endpoint from the Flink external service.
One more concern is that, if the operator manage the multiple namespace, the
rest url of \{{serviceName.namespace}} may not enough, it can not access across
the namespace.
> Revisit the create of RestClusterClient
> ---------------------------------------
>
> Key: FLINK-26356
> URL: https://issues.apache.org/jira/browse/FLINK-26356
> Project: Flink
> Issue Type: Sub-task
> Components: Kubernetes Operator
> Reporter: Aitozi
> Priority: Major
>
> The clusterClient is built as below. The config is mixed up with the
> FlinkDeploymentSpec and local default config.
> {code:java}
> final int port = config.getInteger(RestOptions.PORT);
> final String host =
> config.getString(
> RestOptions.ADDRESS, String.format("%s-rest.%s", clusterId,
> namespace));
> final String restServerAddress = String.format("http://%s:%s";, host, port);
> {code}
> But the {{RestOptions.ADDRESS}} is generated at the entrypoint when the HA is
> enabled, so the option can not obtain from the FlinkDeploymentSpec.
> Furthermore, the default rest url is not suitable for all the service type. I
> think we should extract the rest endpoint from the Flink external service.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
