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

Commit

Permalink
comment
Browse files Browse the repository at this point in the history
  • Loading branch information
@jeevb
jeevb committed Apr 25, 2023
1 parent 3c1f838 commit bd6d12d
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion go/tasks/plugins/k8s/spark/spark.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -236,7 +236,9 @@ func (sparkResourceHandler) BuildResource(ctx context.Context, taskCtx pluginsCo
j.Spec.MainClass = &sparkJob.MainClass
}

// Add non-interruptible node selector requirements to driver pod
// Spark driver pods should always run as non-interruptible. As such, we hardcode
// `interruptible=false` to explicitly add non-interruptible node selector
// requirements to the driver pods
flytek8s.ApplyInterruptibleNodeSelectorRequirement(false, j.Spec.Driver.Affinity)

// Add Interruptible Tolerations/NodeSelector to only Executor pods.
Expand Down

0 comments on commit bd6d12d

Please sign in to comment.