Skip to content

Commit 763682d

Browse files
authored
Fix: should not add emptyDir sizeLimit conf if it is nil (#2305)
Signed-off-by: Yi Chen <[email protected]>
1 parent 171e429 commit 763682d

File tree

1 file changed

+14
-12
lines changed

1 file changed

+14
-12
lines changed

internal/controller/sparkapplication/submission.go

+14-12
Original file line numberDiff line numberDiff line change
@@ -502,20 +502,22 @@ func driverVolumeMountsOption(app *v1beta2.SparkApplication) ([]string, error) {
502502

503503
switch volumeType {
504504
case common.VolumeTypeEmptyDir:
505-
args = append(
506-
args,
507-
"--conf",
508-
fmt.Sprintf(
509-
"%s=%s",
505+
if volume.EmptyDir.SizeLimit != nil {
506+
args = append(
507+
args,
508+
"--conf",
510509
fmt.Sprintf(
511-
common.SparkKubernetesDriverVolumesOptionsTemplate,
512-
common.VolumeTypeEmptyDir,
513-
volume.Name,
514-
"sizeLimit",
510+
"%s=%s",
511+
fmt.Sprintf(
512+
common.SparkKubernetesDriverVolumesOptionsTemplate,
513+
common.VolumeTypeEmptyDir,
514+
volume.Name,
515+
"sizeLimit",
516+
),
517+
volume.EmptyDir.SizeLimit.String(),
515518
),
516-
volume.EmptyDir.SizeLimit.String(),
517-
),
518-
)
519+
)
520+
}
519521
case common.VolumeTypeHostPath:
520522
args = append(
521523
args,

0 commit comments

Comments
 (0)