You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2023/08/25 05:46:58 UTC

[incubator-streampark] branch dev-2.1.2 updated: Flink job batch mode bug fixed.

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 3adfcec8a Flink job batch mode bug fixed.
3adfcec8a is described below

commit 3adfcec8a2ea8725f68a806c3b22a5c14577be58
Author: benjobs <be...@gmail.com>
AuthorDate: Fri Aug 25 13:46:48 2023 +0800

    Flink job batch mode bug fixed.
---
 .../scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala
index 5d2eee224..31f0e4233 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala
@@ -236,8 +236,7 @@ private[flink] class FlinkTableInitializer(args: Array[String], apiType: ApiType
         }
     }
 
-    val mode = Try(TableMode.withName(parameter.get(KEY_FLINK_TABLE_MODE))).getOrElse(tableMode)
-    mode match {
+    tableMode match {
       case TableMode.batch =>
         logInfo(s"components should work in $tableMode mode")
         builder.inBatchMode()