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 <[email protected]>
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()