You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@streampark.apache.org by ya...@apache.org on 2022/10/12 10:08:11 UTC

[incubator-streampark] branch dev updated (201d20b80 -> 64fed2aac)

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

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


    from 201d20b80 [Improve] Refactor the AlertException (#1811)
     add 64fed2aac [buf] After optimizing the core parameter. job submit failed bug fix (#1820)

No new revisions were added by this update.

Summary of changes:
 .../flink/core/FlinkStreamingInitializer.scala     |  64 +++---
 .../flink/core/FlinkTableInitializer.scala         | 102 +++++----
 .../flink/core/FlinkTableInitializer.scala         | 242 ---------------------
 .../flink/core/FlinkTableInitializer.scala         | 225 -------------------
 .../flink/core/FlinkTableInitializer.scala         | 224 -------------------
 5 files changed, 87 insertions(+), 770 deletions(-)
 rename streampark-flink/streampark-flink-shims/{streampark-flink-shims_flink-1.12 => streampark-flink-shims-base}/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala (75%)
 delete mode 100644 streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala
 delete mode 100644 streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala
 delete mode 100644 streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala