[incubator-streampark] branch dev-2.1.2 updated: checkstyle improvements

[benjobs]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev-2.1.2
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev-2.1.2 by this push:
     new 271f9f020 checkstyle improvements
271f9f020 is described below

commit 271f9f02080aa4a0c604962dfb186e41b6c18c10
Author: benjobs <benj...@apache.org>
AuthorDate: Thu Oct 5 17:05:09 2023 +0800

    checkstyle improvements
---
 .../org/apache/streampark/flink/core/scala/DataStreamExt.scala | 10 +++-------
 .../apache/streampark/flink/proxy/ChildFirstClassLoader.scala  |  8 +-------
 2 files changed, 4 insertions(+), 14 deletions(-)

diff --git 
a/streampark-flink/streampark-flink-core/src/main/scala/org/apache/streampark/flink/core/scala/DataStreamExt.scala
 
b/streampark-flink/streampark-flink-core/src/main/scala/org/apache/streampark/flink/core/scala/DataStreamExt.scala
index c1e925e0d..5e2805aa1 100644
--- 
a/streampark-flink/streampark-flink-core/src/main/scala/org/apache/streampark/flink/core/scala/DataStreamExt.scala
+++ 
b/streampark-flink/streampark-flink-core/src/main/scala/org/apache/streampark/flink/core/scala/DataStreamExt.scala
@@ -38,15 +38,11 @@ object DataStreamExt {
   class DataStream[T: TypeInformation](dataStream: DStream[T]) {
 
     def sideOut(fun: (T, ProcFunc[T, T]#Context) => Unit): DStream[T] =
-      dataStream.process(new ProcFunc[T, T] {
-        override def processElement(
-            value: T,
-            ctx: ProcFunc[T, T]#Context,
-            out: Collector[T]): Unit = {
+      dataStream.process(
+        (value: T, ctx: ProcFunc[T, T]#Context, out: Collector[T]) => {
           fun(value, ctx)
           out.collect(value)
-        }
-      })
+        })
 
     def sideGet[R: TypeInformation](sideTag: String): DStream[R] =
       dataStream.getSideOutput(new OutputTag[R](sideTag))
diff --git 
a/streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/ChildFirstClassLoader.scala
 
b/streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/ChildFirstClassLoader.scala
index 7db1fbe90..2d8f5cde3 100644
--- 
a/streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/ChildFirstClassLoader.scala
+++ 
b/streampark-flink/streampark-flink-proxy/src/main/scala/org/apache/streampark/flink/proxy/ChildFirstClassLoader.scala
@@ -43,13 +43,7 @@ class ChildFirstClassLoader(
   ClassLoader.registerAsParallelCapable()
 
   def this(urls: Array[URL], parent: ClassLoader, flinkResourcePattern: 
Pattern) {
-    this(
-      urls,
-      parent,
-      flinkResourcePattern,
-      new Consumer[Throwable] {
-        override def accept(t: Throwable): Unit = {}
-      })
+    this(urls, parent, flinkResourcePattern, (_: Throwable) => {})
   }
 
   private val FLINK_PATTERN =