[Impeove] hadoopUtils minor improvement

apache · Aug 31, 2024 · 55ad9b6 · 55ad9b6
1 parent 1eaaecf
commit 55ad9b6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/streampark-common/src/main/scala/org/apache/streampark/common/util/ClassLoaderUtils.scala b/streampark-common/src/main/scala/org/apache/streampark/common/util/ClassLoaderUtils.scala
@@ -139,7 +139,7 @@ object ClassLoaderUtils extends Logger {
         } catch {
           case _: NoSuchFieldException =>
             throw new UnsupportedOperationException(
-              s"Add resource to classpath unsupported jdk version: ${System.getProperty("java.version")}")
+              s"Add resource to classpath unsupported, jdk version: ${System.getProperty("java.version")}")
         }
     }
   }

diff --git a/streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopUtils.scala b/streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopUtils.scala
@@ -128,7 +128,10 @@ object HadoopUtils extends Logger {
   def hadoopConf: Configuration = Option(reusableConf).getOrElse {
     reusableConf = getConfigurationFromHadoopConfDir(hadoopConfDir)
     // add hadoopConfDir to classpath...you know why???
-    ClassLoaderUtils.loadResource(hadoopConfDir)
+    Try(ClassLoaderUtils.loadResource(hadoopConfDir)) match {
+      case Failure(e) => logWarn(s"Load hadoop resource to classpath failed. $e")
+      case _ =>
+    }
 
     if (StringUtils.isBlank(reusableConf.get("hadoop.tmp.dir"))) {
       reusableConf.set("hadoop.tmp.dir", "/tmp")