[Build] Remove Scala overall regression test and post-migration cleanup

streampark-common/src/main/java/org/apache/streampark/common/conf/FlinkVersion.java

@@ -23,16 +23,15 @@
 
 import java.io.File;
 import java.io.Serializable;
+import java.net.MalformedURLException;
 import java.net.URL;
 import java.util.Arrays;
+import java.util.Collections;
 import java.util.List;
-import java.util.function.Consumer;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
-import scala.collection.JavaConverters;
-
 /** @param flinkHome actual flink home that must be a readable local path */
 public class FlinkVersion implements Serializable {
 
@@ -85,11 +84,6 @@ public String version() {
         return getVersion();
     }
 
-    /** Scala API alias for {@link #getFlinkLibs()}. */
-    public scala.collection.immutable.List<URL> flinkLibs() throws Exception {
-        return JavaConverters.asScalaIteratorConverter(getFlinkLibs().iterator()).asScala().toList();
-    }
-
     public String getScalaVersion() {
         if (scalaVersion == null) {
             Matcher matcher = FLINK_SCALA_VERSION_PATTERN.matcher(getFlinkDistJar().getName());
@@ -123,13 +117,13 @@ public File getFlinkLib() {
     public List<URL> getFlinkLibs() throws Exception {
         File[] files = getFlinkLib().listFiles();
         if (files == null) {
-            return Arrays.asList();
+            return Collections.emptyList();
         }
         return Arrays.stream(files).map(f -> {
             try {
                 return f.toURI().toURL();
-            } catch (Exception e) {
-                throw new RuntimeException(e);
+            } catch (MalformedURLException e) {
+                throw new IllegalArgumentException("Invalid Flink lib URL: " + f, e);
             }
         }).collect(Collectors.toList());
     }
@@ -147,22 +141,18 @@ public String getVersion() {
                 CommandUtils.execute(
                     getFlinkLib().getAbsolutePath(),
                     cmd,
-                    new Consumer<String>() {
-
-                        @Override
-                        public void accept(String out) {
-                            buffer.append(out).append("\n");
-                            Matcher matcher = FLINK_VERSION_PATTERN.matcher(out);
-                            if (matcher.find()) {
-                                String ver = matcher.group(1);
-                                Matcher m1 = APACHE_FLINK_VERSION_PATTERN.matcher(ver);
-                                if (m1.find()) {
+                    out -> {
+                        buffer.append(out).append("\n");
+                        Matcher matcher = FLINK_VERSION_PATTERN.matcher(out);
+                        if (matcher.find()) {
+                            String ver = matcher.group(1);
+                            Matcher m1 = APACHE_FLINK_VERSION_PATTERN.matcher(ver);
+                            if (m1.find()) {
+                                flinkVersion[0] = ver;
+                            } else {
+                                Matcher m2 = OTHER_FLINK_VERSION_PATTERN.matcher(ver);
+                                if (m2.find()) {
                                     flinkVersion[0] = ver;
-                                } else {
-                                    Matcher m2 = OTHER_FLINK_VERSION_PATTERN.matcher(ver);
-                                    if (m2.find()) {
-                                        flinkVersion[0] = ver;
-                                    }
                                 }
                             }
                         }

streampark-common/src/main/java/org/apache/streampark/common/conf/SparkVersion.java

@@ -66,7 +66,7 @@ private static String[] parseVersion(String sparkHome) {
                     sparkVersion[1] = m1.group(1);
             });
         } catch (Exception e) {
-            throw new RuntimeException(e);
+            throw new IllegalStateException("Failed to parse Spark version from " + sparkHome, e);
         }
         LOG.info("[StreamPark] {}", buffer);
         if (sparkVersion[0] == null || sparkVersion[1] == null) {

streampark-common/src/main/java/org/apache/streampark/common/util/AutoCloseUtils.java

@@ -44,7 +44,7 @@ public static <T extends AutoCloseable, R> R using(
             if (e instanceof Error) {
                 throw (Error) e;
             }
-            throw new RuntimeException(e);
+            throw new IllegalStateException(e);
         }
     }
 }

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

@@ -68,7 +68,7 @@ public static void loadJar(String jarFilePath) {
         try {
             loadPath(f.getAbsolutePath());
         } catch (Exception e) {
-            throw new RuntimeException(e);
+            throw new IllegalStateException("Failed to load jar: " + jarFilePath, e);
         }
     }
 
@@ -91,7 +91,7 @@ public static void loadJars(String path) {
             try {
                 loadPath(x.getAbsolutePath());
             } catch (Exception e) {
-                throw new RuntimeException(e);
+                throw new IllegalStateException("Failed to load jar: " + x.getAbsolutePath(), e);
             }
         }
     }

streampark-common/src/main/java/org/apache/streampark/common/util/CommandUtils.java

@@ -59,9 +59,9 @@ public static CommandResult execute(String command) {
             return new CommandResult(code, buffer.toString());
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
-            throw new RuntimeException(e);
+            throw new IllegalStateException(e);
         } catch (Exception e) {
-            throw new RuntimeException(e);
+            throw new IllegalStateException(e);
         }
     }
 
@@ -96,9 +96,9 @@ public static int execute(String directory, Iterable<String> commands, Consumer<
             return waitFor(process);
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
-            throw new RuntimeException(e);
+            throw new IllegalStateException(e);
         } catch (Exception e) {
-            throw new RuntimeException(e);
+            throw new IllegalStateException(e);
         }
     }
 

streampark-common/src/main/java/org/apache/streampark/common/util/ExceptionUtils.java

@@ -62,9 +62,9 @@ public static <I, O> O wrapRuntimeException(I input, WrapperRuntimeExceptionHand
             return handler.handle(input);
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
-            throw new RuntimeException(e);
+            throw new IllegalStateException(e);
         } catch (Exception e) {
-            throw new RuntimeException(e);
+            throw new IllegalStateException(e);
         }
     }
 }

streampark-common/src/main/java/org/apache/streampark/common/util/FileUtils.java

@@ -85,7 +85,7 @@ private static String bytesToHexString(byte[] src) {
 
     public static boolean isJarFileType(InputStream input) {
         if (input == null) {
-            throw new RuntimeException("The inputStream can not be null");
+            throw new IllegalArgumentException("The inputStream can not be null");
         }
         return AutoCloseUtils.using(
             input,
@@ -94,7 +94,7 @@ public static boolean isJarFileType(InputStream input) {
                 try {
                     in.read(b, 0, b.length);
                 } catch (IOException e) {
-                    throw new RuntimeException(e);
+                    throw new IllegalStateException("Failed to read jar file header", e);
                 }
                 return bytesToHexString(b);
             })
@@ -103,7 +103,7 @@ public static boolean isJarFileType(InputStream input) {
 
     public static boolean isJarFileType(File file) throws IOException {
         if (!file.exists() || !file.isFile()) {
-            throw new RuntimeException("The file does not exist or the path is a directory");
+            throw new IllegalArgumentException("The file does not exist or the path is a directory");
         }
         return isJarFileType(new FileInputStream(file));
     }
@@ -174,7 +174,7 @@ public static List<URL> listFileAsURL(String dirPath) {
                     try {
                         urls.add(f.toURI().toURL());
                     } catch (Exception e) {
-                        throw new RuntimeException(e);
+                        throw new IllegalStateException("Failed to convert file to URL: " + f, e);
                     }
                 }
                 return urls;
@@ -206,7 +206,7 @@ public static boolean equals(File file1, File file2) {
         try {
             return equalsInternal(file1, file2);
         } catch (IOException e) {
-            throw new RuntimeException(e);
+            throw new IllegalStateException("Failed to compare files", e);
         }
     }
 
@@ -310,7 +310,7 @@ public static String tailOf(String path, int offset, int limit) {
             }
             return null;
         } catch (IOException e) {
-            throw new RuntimeException(e);
+            throw new IllegalStateException("Failed to read tail of file: " + path, e);
         }
     }
 

streampark-common/src/main/java/org/apache/streampark/common/util/FlinkConfigurationUtils.java

@@ -61,7 +61,7 @@ public static Map<String, String> loadFlinkConf(File file) {
             return loadFlinkConf(
                 org.apache.commons.io.FileUtils.readFileToString(file, StandardCharsets.UTF_8));
         } catch (IOException e) {
-            throw new RuntimeException(e);
+            throw new IllegalStateException("Failed to read Flink configuration file: " + file, e);
         }
     }
 
@@ -79,7 +79,7 @@ public static Map<String, String> loadLegacyFlinkConf(File file) {
             return loadLegacyFlinkConf(
                 org.apache.commons.io.FileUtils.readFileToString(file, StandardCharsets.UTF_8));
         } catch (IOException e) {
-            throw new RuntimeException(e);
+            throw new IllegalStateException("Failed to read legacy Flink configuration file: " + file, e);
         }
     }
 

streampark-common/src/main/java/org/apache/streampark/common/util/HBaseClient.java

@@ -76,7 +76,7 @@ public static HBaseClient apply(Properties prop) {
                             }));
                 return connection;
             } catch (Exception e) {
-                throw new RuntimeException(e);
+                throw new IllegalStateException("Failed to create HBase connection", e);
             }
         });
     }