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 2022/11/26 09:39:05 UTC

[incubator-streampark] branch session-cluster updated (add72fef7 -> 8d233117a)

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

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


    from add72fef7 [Bug] flink cluster bug fixed
     add 8d233117a [Bug] deploy flink on yarn-session cluster bug fixed

No new revisions were added by this update.

Summary of changes:
 .../console/core/entity/Application.java           |  5 --
 .../console/core/entity/FlinkCluster.java          | 63 +++++++++-------------
 .../core/service/impl/ApplicationServiceImpl.java  |  4 --
 .../core/service/impl/FlinkClusterServiceImpl.java | 20 ++-----
 .../src/api/flink/app/app.type.ts                  |  2 -
 .../src/locales/lang/en/flink/app.ts               |  2 -
 .../src/locales/lang/en/flink/setting.ts           |  2 +-
 .../src/locales/lang/zh-CN/flink/app.ts            |  2 -
 .../src/locales/lang/zh-CN/flink/setting.ts        |  2 +-
 .../src/views/flink/app/Add.vue                    | 11 +---
 .../src/views/flink/app/EditFlink.vue              |  1 -
 .../src/views/flink/app/EditStreamPark.vue         | 24 ---------
 .../flink/app/hooks/useCreateAndEditSchema.ts      | 12 ++---
 .../src/views/flink/app/hooks/useFlinkSchema.ts    | 20 +++----
 .../src/views/flink/app/utils/index.ts             |  1 -
 .../views/flink/setting/hooks/useClusterSetting.ts |  4 +-
 .../flink/submit/impl/YarnSessionSubmit.scala      |  9 ++--
 .../flink/submit/trait/YarnSubmitTrait.scala       |  2 -
 18 files changed, 54 insertions(+), 132 deletions(-)