commit 37f7067ec8f1913fff98c9dc0e782a23df92cffd
author wuzhenhua <102498303+wuzhenhua01@users.noreply.github.com> Mon Aug 04 23:16:35 2025 +0800
committer GitHub <noreply@github.com> Mon Aug 04 23:16:35 2025 +0800
tree c29e6513411402574dbb80a397f3a02efad2a9a0
parent 04a84293e7f494da812b90c65e0c727d4339c31a

[Fix-17036] should reconnect hdfs after renew tgt (#17394)

dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java

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 cf6bb78..cf7dc91 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 @@
                         .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");