Make spark executor set ownerreference correctly

This commit is contained in:
Lee moon soo 2018-11-25 08:16:39 +09:00
parent 1a3a070987
commit 3b652a48e7

View file

@ -309,7 +309,7 @@ public class K8sRemoteInterpreterProcess extends RemoteInterpreterProcess {
options.append(" --deploy-mode client");
options.append(" --conf spark.kubernetes.namespace=" + kubectl.getNamespace());
options.append(" --conf spark.executor.instances=1");
options.append(" --conf spark.driver.pod.name=" + getPodName());
options.append(" --conf spark.kubernetes.driver.pod.name=" + getPodName());
options.append(" --conf spark.kubernetes.container.image=" + sparkImage);
options.append(" --conf spark.driver.bindAddress=0.0.0.0");
options.append(" --conf spark.driver.host=" + getInterpreterPodDnsName());