The current Java version of StreamPark is still 1.8, but Java 11 has become the mainstream version of Java. Many new versions of Java ecosystem libraries are compiled based on Java 11, including Flink and Spark, which have provided support for Java 11 early on.
StreamPark's upgrade to Java 11 is considered from the following aspects： Flink: Flink supports Java 11 starting from version 1.10[1]. Spark: Spark 2.4.x and 3.x uses Scala version 2.12, so Java 11 will work with that version. Streampark itself: The Java code of StreamPark can be compiled successfully in Java 11, and the Scala code based on Scala 2.12 which naturally supports Java 11. Due to the extensive use of SPI and reflection mechanisms within StreamPark, it may be necessary to add additional JVM parameter --add-opens in the program startup script to eliminate unsafe reflection warnings. Reference: GitHub issue: https://github.com/apache/incubator-streampark/issues/2961 [1] https://issues.apache.org/jira/browse/FLINK-10725 Best, Linying Assad
