diff --git a/spark-submission-worker/src/main/java/org/apache/spark/k8s/operator/SparkClusterResourceSpec.java b/spark-submission-worker/src/main/java/org/apache/spark/k8s/operator/SparkClusterResourceSpec.java index 69fa0262..04e55817 100644 --- a/spark-submission-worker/src/main/java/org/apache/spark/k8s/operator/SparkClusterResourceSpec.java +++ b/spark-submission-worker/src/main/java/org/apache/spark/k8s/operator/SparkClusterResourceSpec.java @@ -261,6 +261,10 @@ private static StatefulSet buildWorkerStatefulSet( + name + "-master-svc:7077 && while /opt/spark/sbin/spark-daemon.sh status " + "org.apache.spark.deploy.worker.Worker 1; do sleep 1; done") + .addNewPort() + .withName("web") + .withContainerPort(8081) + .endPort() .endContainer() .endSpec() .endTemplate()