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

wuzhenhua01 · web-flow · commit 37f7067ec8f1 · 2025-08-04T23:16:35.000+08:00
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
@@ -112,11 +112,12 @@ private void init() {
                         .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");

Original file line number	Diff line number	Diff line change
`@@ -112,11 +112,12 @@ private void init() {`
`112`	`112`	`.scheduleWithFixedDelay(() -> {`
`113`	`113`	`try {`
`114`	`114`	`UserGroupInformation.getLoginUser().checkTGTAndReloginFromKeytab();`
	`115`	`+ fs = FileSystem.get(configuration);`
`115`	`116`	`log.info("checkTGTAndReloginFromKeytab finished");`
`116`	`117`	`} catch (Exception e) {`
`117`	`118`	`log.error("checkTGTAndReloginFromKeytab Error", e);`
`118`	`119`	`}`
`119`		`- }, kerberosExpireTimeInHour, kerberosExpireTimeInHour, TimeUnit.MINUTES);`
	`120`	`+ }, kerberosExpireTimeInHour, kerberosExpireTimeInHour, TimeUnit.HOURS);`
`120`	`121`	`}`
`121`	`122`	`fs = FileSystem.get(configuration);`
`122`	`123`	`log.info("Initialize HdfsStorageOperator with kerberos");`