[ISSUE-3061][Improve] Improve streampark-common module base on [4 Exception Processing]

streampark-common/src/main/scala/org/apache/streampark/common/conf/ConfigOption.scala

@@ -50,7 +50,7 @@ case class ConfigOption[T](
     case null =>
       if (required) {
         prop.get(fullKey) match {
-          case null => throw error("is require")
+          case null => throw error("Is require")
           case v => v.toString.cast[T](classType)
         }
       } else {

streampark-common/src/main/scala/org/apache/streampark/common/conf/InternalConfigHolder.scala

@@ -103,7 +103,7 @@ object InternalConfigHolder extends Logger {
             SystemPropertyUtils.get(key) match {
               case v if v != null => v.cast[T](config.classType)
               case _ =>
-                throw new IllegalArgumentException(s"config key has not been registered: $key")
+                throw new IllegalArgumentException(s"Config key has not been registered: $key")
             }
           case conf: InternalOption => conf.defaultValue.asInstanceOf[T]
         }

streampark-common/src/main/scala/org/apache/streampark/common/util/ClassLoaderUtils.scala

@@ -18,7 +18,7 @@ package org.apache.streampark.common.util
 
 import java.io.{File, IOException}
 import java.net.{URL, URLClassLoader}
-import java.util.function.{Consumer, Supplier}
+import java.util.function.Supplier
 
 import scala.collection.mutable.ArrayBuffer
 

streampark-common/src/main/scala/org/apache/streampark/common/util/HadoopUtils.scala

@@ -287,7 +287,7 @@ object HadoopUtils extends Logger {
     val tmpDir = FileUtils.createTempDir()
     val fs = FileSystem.get(new Configuration)
     val sourcePath = fs.makeQualified(new Path(jarOnHdfs))
-    if (!fs.exists(sourcePath)) throw new IOException(s"jar file: $jarOnHdfs doesn't exist.")
+    if (!fs.exists(sourcePath)) throw new IOException(s"Jar file: $jarOnHdfs doesn't exist.")
     val destPath = new Path(tmpDir.getAbsolutePath + "/" + sourcePath.getName)
     fs.copyToLocalFile(sourcePath, destPath)
     new File(destPath.toString).getAbsolutePath

streampark-common/src/main/scala/org/apache/streampark/common/util/Logger.scala

@@ -121,7 +121,7 @@ private[this] object LoggerFactory extends LoggerFactoryBinder {
   override def getLoggerFactory: ILoggerFactory = {
     if (contextSelectorBinder.getContextSelector == null) {
       throw new IllegalStateException(
-        "contextSelector cannot be null. See also " + CoreConstants.CODES_URL + "#null_CS")
+        "'contextSelector' cannot be null. See also " + CoreConstants.CODES_URL + "#null_CS")
     }
     contextSelectorBinder.getContextSelector.getLoggerContext
   }

streampark-common/src/main/scala/org/apache/streampark/common/util/SystemPropertyUtils.scala

@@ -43,7 +43,7 @@ object SystemPropertyUtils extends Logger {
   def get(key: String, default: String): String = {
     require(key != null, "[StreamPark] key must not be null.")
     key match {
-      case empty if empty.isEmpty => throw new IllegalArgumentException("key must not be empty.")
+      case empty if empty.isEmpty => throw new IllegalArgumentException("Key must not be empty.")
       case other =>
         Try {
           System.getSecurityManager match {

streampark-common/src/main/scala/org/apache/streampark/common/util/Utils.scala

@@ -66,7 +66,7 @@ object Utils extends Logger {
 
   def required(expression: Boolean, errorMessage: Any): Unit = {
     if (!expression) {
-      throw new IllegalArgumentException(s"requirement failed: ${errorMessage.toString}")
+      throw new IllegalArgumentException(s"Requirement failed: ${errorMessage.toString}")
     }
   }