diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/KubernetesDriverBuilder.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/KubernetesDriverBuilder.scala index e89e52f1af201..3b69754b9cdf1 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/KubernetesDriverBuilder.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/k8s/submit/KubernetesDriverBuilder.scala @@ -40,7 +40,7 @@ private[spark] class KubernetesDriverBuilder { val userFeatures = conf.get(Config.KUBERNETES_DRIVER_POD_FEATURE_STEPS) .map { className => - val feature = Utils.classForName[Any](className).newInstance() + val feature = Utils.classForName[Any](className).getConstructor().newInstance() val initializedFeature = feature match { // Since 3.3, allow user to implement feature with KubernetesDriverConf case d: KubernetesDriverCustomFeatureConfigStep => diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesExecutorBuilder.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesExecutorBuilder.scala index 1f6d72cb7eee0..67aad00f98543 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesExecutorBuilder.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesExecutorBuilder.scala @@ -43,7 +43,7 @@ private[spark] class KubernetesExecutorBuilder { val userFeatures = conf.get(Config.KUBERNETES_EXECUTOR_POD_FEATURE_STEPS) .map { className => - val feature = Utils.classForName[Any](className).newInstance() + val feature = Utils.classForName[Any](className).getConstructor().newInstance() val initializedFeature = feature match { // Since 3.3, allow user to implement feature with KubernetesExecutorConf case e: KubernetesExecutorCustomFeatureConfigStep =>