We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4117c52 commit 78adb11Copy full SHA for 78adb11
syncmaster/worker/spark.py
@@ -4,6 +4,7 @@
4
5
import logging
6
import math
7
+import socket
8
from typing import TYPE_CHECKING
9
10
from onetl.connection.kerberos_helpers import kinit_password
@@ -85,6 +86,9 @@ def get_spark_session_conf(
85
86
config["spark.dynamicAllocation.maxExecutors"] = tasks # yarn
87
config["spark.kubernetes.executor.limit.cores"] = cores_per_task # k8s
88
89
+ # https://spark.apache.org/docs/latest/running-on-kubernetes.html#client-mode-executor-pod-garbage-collection
90
+ config["spark.kubernetes.driver.pod.name"] = socket.gethostname()
91
+
92
if maven_packages:
93
log.debug("Include Maven packages: %s", maven_packages)
94
config["spark.jars.packages"] = ",".join(maven_packages)
0 commit comments