From 6453fecab7701edcef83b63b95dba7e75b34f7df Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?M=C3=BCcahit=20Kantepe?= Date: Wed, 26 Apr 2023 21:29:59 -0700 Subject: [PATCH] Update spark.go MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Mücahit Kantepe --- go/tasks/plugins/k8s/spark/spark.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/go/tasks/plugins/k8s/spark/spark.go b/go/tasks/plugins/k8s/spark/spark.go index 8e2ee5ee9..f499179b2 100755 --- a/go/tasks/plugins/k8s/spark/spark.go +++ b/go/tasks/plugins/k8s/spark/spark.go @@ -407,7 +407,7 @@ func getEventInfoForSpark(sj *sparkOp.SparkApplication) (*pluginsCore.TaskInfo, }) } } else if sj.Status.AppState.State == sparkOp.RunningState && sj.Status.DriverInfo.WebUIIngressAddress != "" { - // Older versions of spark-operator does not have http:// but newer versions have. + // Older versions of spark-operator does not append http:// but newer versions do. uri := strings.TrimPrefix(sj.Status.DriverInfo.WebUIIngressAddress, "http://") customInfoMap[sparkDriverUI] = fmt.Sprintf("https://%s", uri) // Custom doesn't work unless the UI has a custom plugin to parse this, hence add to Logs as well.