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
