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: [email protected]
For additional commands, e-mail: [email protected]
