tweise commented on a change in pull request #54:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/54#discussion_r825519428
##########
File path:
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java
##########
@@ -140,8 +141,13 @@ public boolean isJobManagerPortReady(Configuration config)
{
final String clusterId =
config.get(KubernetesConfigOptions.CLUSTER_ID);
final String namespace = config.get(KubernetesConfigOptions.NAMESPACE);
final int port = config.getInteger(RestOptions.PORT);
- final String host =
+ String host =
ExternalServiceDecorator.getNamespacedExternalServiceName(clusterId, namespace);
+ if (EnvUtils.get("KUBERNETES_SERVICE_HOST") == null) {
+ // not running in k8s, simplify local development
+ // TODO: make this an operator config and pass that config through
Review comment:
Haha yes, that is actually what I'm planning to do if the change as such
is acceptable. Will have to pass `DefaultConfig` for that, not just the
effective config for Flink. But that is probably a change worthwhile doing
anyways as we are likely to add more settings that govern the operator behavior
going forward.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
