Skip to content
This repository has been archived by the owner on Oct 9, 2023. It is now read-only.

Commit

Permalink
Update spark.go
Browse files Browse the repository at this point in the history
Signed-off-by: Mücahit Kantepe <[email protected]>
  • Loading branch information
mucahitkantepe authored Apr 27, 2023
1 parent a069bba commit 6453fec
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion go/tasks/plugins/k8s/spark/spark.go
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down

0 comments on commit 6453fec

Please sign in to comment.