(dolphinscheduler) branch dev updated: [Fix-17036] should reconnect hdfs after renew tgt (#17394)

[zihaoxiang]

This is an automated email from the ASF dual-hosted git repository.

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 37f7067ec8 [Fix-17036] should reconnect hdfs after renew tgt (#17394)
37f7067ec8 is described below

commit 37f7067ec8f1913fff98c9dc0e782a23df92cffd
Author: wuzhenhua <102498303+wuzhenhu...@users.noreply.github.com>
AuthorDate: Mon Aug 4 23:16:35 2025 +0800

    [Fix-17036] should reconnect hdfs after renew tgt (#17394)
---
 .../dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java
 
b/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java
index cf6bb78557..cf7dc91c1a 100644
--- 
a/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java
+++ 
b/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java
@@ -112,11 +112,12 @@ public class HdfsStorageOperator extends 
AbstractStorageOperator implements Clos
                         .scheduleWithFixedDelay(() -> {
                             try {
                                 
UserGroupInformation.getLoginUser().checkTGTAndReloginFromKeytab();
+                                fs = FileSystem.get(configuration);
                                 log.info("checkTGTAndReloginFromKeytab 
finished");
                             } catch (Exception e) {
                                 log.error("checkTGTAndReloginFromKeytab 
Error", e);
                             }
-                        }, kerberosExpireTimeInHour, kerberosExpireTimeInHour, 
TimeUnit.MINUTES);
+                        }, kerberosExpireTimeInHour, kerberosExpireTimeInHour, 
TimeUnit.HOURS);
             }
             fs = FileSystem.get(configuration);
             log.info("Initialize HdfsStorageOperator with kerberos");