You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by wa...@apache.org on 2022/04/22 06:32:21 UTC

[flink-kubernetes-operator] branch main updated (805fef5 -> f7ee710)

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

wangyang0918 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git


    from 805fef5  [FLINK-27023] Unify flink and operator configuration
     add f7ee710  [FLINK-27161] Support to fetch user jar from different sources for session job

No new revisions were added by this update.

Summary of changes:
 docs/content/docs/operations/configuration.md      |   1 +
 .../flink/kubernetes/operator/FlinkOperator.java   |   5 +
 .../{JarResolver.java => ArtifactFetcher.java}     |  26 ++--
 .../operator/artifact/ArtifactManager.java         |  74 ++++++++++
 .../artifact/FileSystemBasedArtifactFetcher.java   |  52 +++++++
 .../operator/artifact/HttpArtifactFetcher.java     |  50 +++++++
 .../config/FlinkOperatorConfiguration.java         |   8 +-
 .../config/KubernetesOperatorConfigOptions.java    |   6 +
 .../kubernetes/operator/service/FlinkService.java  |  21 +--
 .../kubernetes/operator/TestingFlinkService.java   |   3 +-
 .../operator/artifact/ArtifactManagerTest.java     | 154 +++++++++++++++++++++
 .../operator/artifact/JarResolverTest.java         |  35 -----
 12 files changed, 376 insertions(+), 59 deletions(-)
 rename flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/{JarResolver.java => ArtifactFetcher.java} (65%)
 create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/ArtifactManager.java
 create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/FileSystemBasedArtifactFetcher.java
 create mode 100644 flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/HttpArtifactFetcher.java
 create mode 100644 flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/artifact/ArtifactManagerTest.java
 delete mode 100644 flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/artifact/JarResolverTest.java