From 50afa714d4c5feea35ca6adf32a97e8af59173ad Mon Sep 17 00:00:00 2001 From: Devesh Agrawal Date: Wed, 19 Aug 2020 16:33:07 -0700 Subject: [PATCH] [K8s] Fix K8s integration test --- .../spark/deploy/k8s/integrationtest/DecommissionSuite.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/DecommissionSuite.scala b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/DecommissionSuite.scala index fd67a03160af..6bc1ec1d201d 100644 --- a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/DecommissionSuite.scala +++ b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/DecommissionSuite.scala @@ -17,7 +17,6 @@ package org.apache.spark.deploy.k8s.integrationtest import org.apache.spark.internal.config -import org.apache.spark.internal.config.Worker private[spark] trait DecommissionSuite { k8sSuite: KubernetesSuite => @@ -26,7 +25,7 @@ private[spark] trait DecommissionSuite { k8sSuite: KubernetesSuite => test("Test basic decommissioning", k8sTestTag) { sparkAppConf - .set(Worker.WORKER_DECOMMISSION_ENABLED.key, "true") + .set(config.DECOMMISSION_ENABLED.key, "true") .set("spark.kubernetes.pyspark.pythonVersion", "3") .set("spark.kubernetes.container.image", pyImage) .set(config.STORAGE_DECOMMISSION_ENABLED.key, "true")