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
