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 afce4ddd8d8 Fix: Replace print with logger in Hive Hook kill method
(#62990)
afce4ddd8d8 is described below
commit afce4ddd8d8a4b1c6b8892e0882bac10b1073ceb
Author: ANKIT KUMAR <[email protected]>
AuthorDate: Wed Mar 11 00:52:09 2026 +0530
Fix: Replace print with logger in Hive Hook kill method (#62990)
Signed-off-by: Ankit Kumar <[email protected]>
---
providers/apache/hive/src/airflow/providers/apache/hive/hooks/hive.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/providers/apache/hive/src/airflow/providers/apache/hive/hooks/hive.py
b/providers/apache/hive/src/airflow/providers/apache/hive/hooks/hive.py
index e5ce0cc6047..e8b299d42ff 100644
--- a/providers/apache/hive/src/airflow/providers/apache/hive/hooks/hive.py
+++ b/providers/apache/hive/src/airflow/providers/apache/hive/hooks/hive.py
@@ -527,7 +527,7 @@ class HiveCliHook(BaseHook):
"""Kill Hive cli command."""
if hasattr(self, "sub_process"):
if self.sub_process.poll() is None:
- print("Killing the Hive job")
+ self.log.info("Killing the Hive job")
self.sub_process.terminate()
time.sleep(60)
self.sub_process.kill()