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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 7232da621 Modify RemoteClient log (#2908)
7232da621 is described below

commit 7232da621567e0f5b1e64cce304dfca566f178eb
Author: ChengJie1053 <[email protected]>
AuthorDate: Fri Jul 28 17:13:07 2023 +0800

    Modify RemoteClient log (#2908)
---
 .../scala/org/apache/streampark/flink/client/impl/RemoteClient.scala    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/RemoteClient.scala
 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/RemoteClient.scala
index a696e9c7f..d38f5254a 100644
--- 
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/RemoteClient.scala
+++ 
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/impl/RemoteClient.scala
@@ -44,7 +44,7 @@ object RemoteClient extends FlinkClientTrait {
   override def doSubmit(
       submitRequest: SubmitRequest,
       flinkConfig: Configuration): SubmitResponse = {
-    // 2) submit job
+    //  submit job
     super.trySubmit(submitRequest, flinkConfig, 
submitRequest.userJarFile)(restApiSubmit)(
       jobGraphSubmit)
 

Reply via email to