[FLINK-23961][kubernetes] Hint user about missing 'kubernetes.cluster…

…-id' config option
zhuoluoy · Sep 8, 2021 · 7e91e82 · 7e91e82
1 parent 37a0e91
commit 7e91e82
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...bernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java b/...bernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java
@@ -85,7 +85,15 @@ public Fabric8FlinkKubeClient(
             Configuration flinkConfig,
             NamespacedKubernetesClient client,
             ExecutorService executorService) {
-        this.clusterId = checkNotNull(flinkConfig.getString(KubernetesConfigOptions.CLUSTER_ID));
+        this.clusterId =
+                flinkConfig
+                        .getOptional(KubernetesConfigOptions.CLUSTER_ID)
+                        .orElseThrow(
+                                () ->
+                                        new IllegalArgumentException(
+                                                String.format(
+                                                        "Configuration option '%s' is not set.",
+                                                        KubernetesConfigOptions.CLUSTER_ID.key())));
         this.namespace = flinkConfig.getString(KubernetesConfigOptions.NAMESPACE);
         this.maxRetryAttempts =
                 flinkConfig.getInteger(