You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by li...@apache.org on 2021/11/28 01:26:02 UTC
[dolphinscheduler] branch dev updated: fix(kerboros): set correct classloader for kerboros conf load in plugin tasks (#7027)
This is an automated email from the ASF dual-hosted git repository.
lidongdai 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 42e20cb fix(kerboros): set correct classloader for kerboros conf load in plugin tasks (#7027)
42e20cb is described below
commit 42e20cbf60b8951ce78cdb77ff0f1d5159df7ad9
Author: sparklezzz <zh...@gmail.com>
AuthorDate: Sun Nov 28 09:25:51 2021 +0800
fix(kerboros): set correct classloader for kerboros conf load in plugin tasks (#7027)
Co-authored-by: xudong.zhang <xu...@nio.com>
---
.../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);
}
/**