This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 73fcb4f55d9 Log on_kill job deletion in kubernetes spark operator at
INFO level (#64633)
73fcb4f55d9 is described below
commit 73fcb4f55d9e2ca7dfb31a72406751f6537c3b66
Author: Sam Wheating <[email protected]>
AuthorDate: Thu Apr 2 20:14:45 2026 +0100
Log on_kill job deletion in kubernetes spark operator at INFO level (#64633)
---
.../src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py
index 6185b3053ef..e1cbe0595f2 100644
---
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py
+++
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py
@@ -421,7 +421,7 @@ class SparkKubernetesOperator(KubernetesPodOperator):
return self.find_spark_job(context, exclude_checked=exclude_checked)
def on_kill(self) -> None:
- self.log.debug("Deleting spark job for task %s", self.task_id)
+ self.log.info("Deleting spark job for task %s", self.task_id)
job_name = self.name
if self.pod and self.pod.metadata and self.pod.metadata.name:
if self.pod.metadata.name.endswith("-driver"):
