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

leonbao pushed a commit to branch 2.0.1-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/2.0.1-prepare by this push:
     new 77f4b0a  fix(kerboros): set correct classloader for kerboros conf load 
in plugin tasks (#7027) (#7064)
77f4b0a is described below

commit 77f4b0aaf58620a5e752bc71ced488738477fb29
Author: Kirs <[email protected]>
AuthorDate: Tue Nov 30 16:27:23 2021 +0800

    fix(kerboros): set correct classloader for kerboros conf load in plugin 
tasks (#7027) (#7064)
    
    Co-authored-by: xudong.zhang <[email protected]>
    
    Co-authored-by: sparklezzz <[email protected]>
    Co-authored-by: xudong.zhang <[email protected]>
---
 .../dolphinscheduler/plugin/datasource/api/utils/CommonUtils.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtils.java
 
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtils.java
index 25b6a59..349638c 100644
--- 
a/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtils.java
+++ 
b/dolphinscheduler-datasource-plugin/dolphinscheduler-datasource-api/src/main/java/org/apache/dolphinscheduler/plugin/datasource/api/utils/CommonUtils.java
@@ -79,7 +79,9 @@ public class CommonUtils {
      * @throws IOException errors
      */
     public static void loadKerberosConf(String javaSecurityKrb5Conf, String 
loginUserKeytabUsername, String loginUserKeytabPath) throws IOException {
-        loadKerberosConf(javaSecurityKrb5Conf, loginUserKeytabUsername, 
loginUserKeytabPath, new Configuration());
+        Configuration configuration = new Configuration();
+        
configuration.setClassLoader(configuration.getClass().getClassLoader());
+        loadKerberosConf(javaSecurityKrb5Conf, loginUserKeytabUsername, 
loginUserKeytabPath, configuration);
     }
 
     /**

Reply via email to