diff --git a/airflow-core/src/airflow/config_templates/airflow_local_settings.py b/airflow-core/src/airflow/config_templates/airflow_local_settings.py index 3cade5678261c..cb1cc364e2ca6 100644 --- a/airflow-core/src/airflow/config_templates/airflow_local_settings.py +++ b/airflow-core/src/airflow/config_templates/airflow_local_settings.py @@ -250,7 +250,7 @@ **( { "base_log_folder": BASE_LOG_FOLDER, - "remote_base": remote_base_log_folder, + "remote_base": urlsplit(remote_base_log_folder).path, "delete_local_copy": delete_local_copy, } | remote_task_handler_kwargs diff --git a/providers/apache/hdfs/src/airflow/providers/apache/hdfs/log/hdfs_task_handler.py b/providers/apache/hdfs/src/airflow/providers/apache/hdfs/log/hdfs_task_handler.py index 4de610203416c..b0b89aad6c70c 100644 --- a/providers/apache/hdfs/src/airflow/providers/apache/hdfs/log/hdfs_task_handler.py +++ b/providers/apache/hdfs/src/airflow/providers/apache/hdfs/log/hdfs_task_handler.py @@ -94,7 +94,7 @@ def __init__(self, base_log_folder: str, hdfs_log_folder: str, **kwargs): self.upload_on_close = True self.io = HdfsRemoteLogIO( - remote_base=hdfs_log_folder, + remote_base=self.remote_base, base_log_folder=base_log_folder, delete_local_copy=kwargs.get( "delete_local_copy", conf.getboolean("logging", "delete_local_logs")