This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
from 975ad4ff2 support spark task (#4102)
add a0541f137 [Improve] spark-job support proxy (#4101)
No new revisions were added by this update.
Summary of changes:
.../streampark/common/enums/FlinkJobType.java | 6 +-
.../streampark/common/enums/SparkJobType.java | 6 +-
.../streampark/console/core/bean/AppControl.java | 2 +
...ller.java => FlinkBuildPipelineController.java} | 2 +-
.../console/core/controller/ProxyController.java | 44 +++++----
.../controller/SparkApplicationController.java | 14 +--
...ller.java => SparkBuildPipelineController.java} | 2 +-
.../core/controller/SparkProxyController.java | 101 ---------------------
.../console/core/entity/FlinkApplication.java | 16 ++--
.../core/entity/FlinkApplicationBackUp.java | 4 +-
.../console/core/entity/SparkApplication.java | 16 ++--
.../core/entity/SparkApplicationBackUp.java | 4 +-
.../console/core/entity/SparkApplicationLog.java | 51 -----------
.../console/core/enums/DistributedTaskEnum.java | 7 +-
.../console/core/enums/SparkOperationEnum.java | 2 +-
.../core/mapper/SparkApplicationLogMapper.java | 25 -----
.../console/core/service/ProxyService.java | 6 +-
.../application/SparkApplicationActionService.java | 2 +-
.../application/SparkApplicationLogService.java | 44 ---------
...Impl.java => FlinkAppBuildPipeServiceImpl.java} | 28 +++---
.../impl/FlinkApplicationActionServiceImpl.java | 29 +++---
.../impl/FlinkApplicationInfoServiceImpl.java | 6 +-
.../impl/FlinkApplicationManageServiceImpl.java | 21 +++--
.../impl/SparkAppBuildPipeServiceImpl.java | 39 ++++----
.../impl/SparkApplicationActionServiceImpl.java | 41 +++++----
.../impl/SparkApplicationConfigServiceImpl.java | 9 +-
.../impl/SparkApplicationLogServiceImpl.java | 57 ------------
.../impl/SparkApplicationManageServiceImpl.java | 27 +++---
.../service/impl/DistributedTaskServiceImpl.java | 4 +-
.../service/impl/FlinkSavepointServiceImpl.java | 8 +-
.../core/service/impl/ProxyServiceImpl.java | 36 ++++----
.../console/core/utils/AlertTemplateUtils.java | 6 +-
.../console/core/watcher/FlinkAppHttpWatcher.java | 14 +--
.../console/core/watcher/SparkAppHttpWatcher.java | 14 +--
.../src/main/resources/db/schema-h2.sql | 20 +---
.../mapper/core/SparkApplicationMapper.xml | 12 +--
.../src/api/spark/app.type.ts | 1 +
.../src/locales/lang/en/flink/app.ts | 2 +-
.../src/locales/lang/en/spark/app.ts | 2 +-
.../src/locales/lang/en/spark/home.ts | 2 +-
.../src/locales/lang/zh-CN/menu.ts | 6 +-
.../src/locales/lang/zh-CN/spark/app.ts | 44 ++++-----
.../src/views/flink/app/View.vue | 1 -
.../flink/app/components/AppDetail/DetailTab.vue | 8 +-
.../src/views/flink/app/data/detail.data.ts | 4 +-
.../src/views/flink/app/hooks/useApp.tsx | 18 ++--
.../src/views/flink/cluster/View.vue | 4 +-
.../src/views/spark/app/components/DetailTab.vue | 14 +--
.../src/views/spark/app/components/State.tsx | 2 +-
.../src/views/spark/app/data/detail.data.ts | 4 +-
.../src/views/spark/app/detail.vue | 4 +-
.../src/views/spark/app/hooks/useSparkAction.tsx | 18 ++--
.../views/spark/app/hooks/useSparkTableAction.ts | 5 +-
.../src/views/spark/app/index.vue | 7 --
.../e2e/cases/FlinkSQL116OnYarnTest.java | 6 +-
.../e2e/cases/FlinkSQL117OnYarnTest.java | 6 +-
.../e2e/cases/FlinkSQL118OnYarnTest.java | 6 +-
.../pages/flink/applications/ApplicationForm.java | 38 ++++----
.../flink/client/bean/SubmitRequest.scala | 4 +-
.../flink/client/impl/YarnApplicationClient.scala | 4 +-
.../flink/client/trait/FlinkClientTrait.scala | 10 +-
.../flink/packer/pipeline/PipelineTypeEnum.java | 4 +-
.../flink/packer/pipeline/BuildRequest.scala | 22 ++---
.../pipeline/impl/FlinkRemoteBuildPipeline.scala | 6 +-
.../impl/FlinkYarnApplicationBuildPipeline.scala | 4 +-
...Pipeline.scala => SparkYarnBuildPipeline.scala} | 21 +++--
.../spark/client/bean/SubmitRequest.scala | 28 +++---
.../spark/client/trait/SparkClientTrait.scala | 2 +-
68 files changed, 372 insertions(+), 660 deletions(-)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/{FlinkApplicationBuildPipelineController.java
=> FlinkBuildPipelineController.java} (98%)
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/{SparkApplicationBuildPipelineController.java
=> SparkBuildPipelineController.java} (98%)
delete mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkProxyController.java
delete mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplicationLog.java
delete mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/mapper/SparkApplicationLogMapper.java
delete mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/SparkApplicationLogService.java
rename
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/{AppBuildPipeServiceImpl.java
=> FlinkAppBuildPipeServiceImpl.java} (98%)
delete mode 100644
streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationLogServiceImpl.java
rename
streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/{SparkYarnApplicationBuildPipeline.scala
=> SparkYarnBuildPipeline.scala} (88%)
