You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by pe...@apache.org on 2023/05/19 03:04:43 UTC
[linkis] branch dev-1.4.0 updated (af0b6e312 -> a5e6991bc)
This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a change to branch dev-1.4.0
in repository https://gitbox.apache.org/repos/asf/linkis.git
from af0b6e312 fix(pom): fix the spark miss jetty-client, and remove the older jesery (#4562)
add a5e6991bc [Feature][Flink] Add task interceptor for FLink EC (#4556)
No new revisions were added by this update.
Summary of changes:
.../flink/config/FlinkEnvConfiguration.scala | 2 +-
.../flink/executor/FlinkOnceExecutor.scala | 16 +++-
.../interceptor/FlinkJobResCleanInterceptor.scala | 93 ++++++++++++++++++++++
.../interceptor/FlinkJobSubmitInterceptor.scala | 35 +++++---
.../factory/FlinkApplicationExecutorFactory.scala | 12 ++-
.../resource/FlinkJobLocalResourceCleaner.scala | 69 ++++++++++++++++
.../flink/resource/FlinkJobResourceCleaner.scala | 23 +++---
7 files changed, 229 insertions(+), 21 deletions(-)
create mode 100644 linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/executor/interceptor/FlinkJobResCleanInterceptor.scala
copy linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/plans/unit/LambdaLogicalUnit.scala => linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/executor/interceptor/FlinkJobSubmitInterceptor.scala (52%)
create mode 100644 linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/resource/FlinkJobLocalResourceCleaner.scala
copy linkis-orchestrator/linkis-orchestrator-core/src/main/scala/org/apache/linkis/orchestrator/plans/unit/LambdaLogicalUnit.scala => linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/resource/FlinkJobResourceCleaner.scala (71%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org