-
Notifications
You must be signed in to change notification settings - Fork 1.4k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Linear search does not account for the case when the container is not found #868
Comments
Yeah, it needs to be guarded against that. Will definitely fix that. However, the operator will not use the pod template support in Spark 3.0 and has no plan to support that given that it already has an API for most pod configuration needs. So there won't be a way for users to use a custom container name for the driver and container. |
I see. |
No, |
Spark 3.0.0-rc1 names the executor pod as "spark-kubernetes-executor". Spark Operator has a configuration constant for that, "executor". Spark Operator searches for "executor" container name, but the container name is "spark-kubernetes-executor". Thus, the following line of code will result in an NPE: As far as I know, there is no other way to rename the executor Pod's container name, then using |
I wasn't aware of the renaming of the default executor container name. It was simply |
Sure, that can work! Apart from that, we are running Spark 3.0.0-rc1 in production with the Spark Operator as we speak without any issues for 12 Spark streaming jobs. |
Good to know that! Will create a PR with the fix. |
Thanks, when it goes live I throw out my podTemplates! :-D |
https://github.com/GoogleCloudPlatform/spark-on-k8s-operator/blob/2e4559eac0f593398d5e19ef85bfc6a5df032033/pkg/webhook/patch.go#L167
When the container not found with the name, hardcoded into the configuration, it should log an error that it was not able to patch the Pod
spec
. Currently, this results in an NPE and panic. In addition, provide a hint to the users that the problem around container naming may be fixed usingspark.kubernetes.executor.podTemplate
.The text was updated successfully, but these errors were encountered: