This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev-2.1.5
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev-2.1.5 by this push:
new 5da3db395 [Improve] FlinkClientHandler rename to FlinkClientEntrypoint
5da3db395 is described below
commit 5da3db39590c17d8b54c6fb2d319fb29d6309245
Author: benjobs <[email protected]>
AuthorDate: Sat Sep 14 20:27:40 2024 +0800
[Improve] FlinkClientHandler rename to FlinkClientEntrypoint
---
.../main/scala/org/apache/streampark/flink/client/FlinkClient.scala | 6 +++---
.../{FlinkClientHandler.scala => FlinkClientEntrypoint.scala} | 2 +-
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/FlinkClient.scala
b/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/FlinkClient.scala
index 867625695..111c24d79 100644
---
a/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/FlinkClient.scala
+++
b/streampark-flink/streampark-flink-client/streampark-flink-client-api/src/main/scala/org/apache/streampark/flink/client/FlinkClient.scala
@@ -28,8 +28,8 @@ import scala.language.{implicitConversions, reflectiveCalls}
import scala.reflect.ClassTag
object FlinkClient extends Logger {
- private[this] val FLINK_CLIENT_HANDLER_CLASS_NAME =
- "org.apache.streampark.flink.client.FlinkClientHandler"
+ private[this] val FLINK_CLIENT_ENTRYPOINT_CLASS_NAME =
+ "org.apache.streampark.flink.client.FlinkClientEntrypoint"
private[this] val SUBMIT_REQUEST =
"org.apache.streampark.flink.client.bean.SubmitRequest" -> "submit"
@@ -80,7 +80,7 @@ object FlinkClient extends Logger {
FlinkShimsProxy.proxy(
flinkVersion,
(classLoader: ClassLoader) => {
- val submitClass =
classLoader.loadClass(FLINK_CLIENT_HANDLER_CLASS_NAME)
+ val submitClass =
classLoader.loadClass(FLINK_CLIENT_ENTRYPOINT_CLASS_NAME)
val requestClass = classLoader.loadClass(requestBody._1)
val method = submitClass.getDeclaredMethod(requestBody._2,
requestClass)
method.setAccessible(true)
diff --git
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/FlinkClientHandler.scala
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/FlinkClientEntrypoint.scala
similarity index 99%
rename from
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/FlinkClientHandler.scala
rename to
streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/FlinkClientEntrypoint.scala
index c6fa402e9..8e24aeed0 100644
---
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/FlinkClientHandler.scala
+++
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/FlinkClientEntrypoint.scala
@@ -23,7 +23,7 @@ import
org.apache.streampark.flink.client.`trait`.FlinkClientTrait
import org.apache.streampark.flink.client.bean._
import org.apache.streampark.flink.client.impl._
-object FlinkClientHandler {
+object FlinkClientEntrypoint {
private[this] val clients: Map[ExecutionMode, FlinkClientTrait] = Map(
LOCAL -> LocalClient,
