Daren Wong created FLINK-29847: ---------------------------------- Summary: Store/cache JarUploadResponseBody Key: FLINK-29847 URL: https://issues.apache.org/jira/browse/FLINK-29847 Project: Flink Issue Type: Improvement Components: Kubernetes Operator Reporter: Daren Wong Fix For: kubernetes-operator-1.3.0
Kubernetes operator currently uploadJar always even when the same JAR has been uploaded to JM previously. For example, this occurs during rollback operation. To improve the performance, we want to cache the JarUploadResponseBody so that in the next runJar operation, kubernetes operator will check the cache and reuse the jar if it's the same JAR. This "cache" can be as simple as storing the uploaded JarFilePath in the CR Status field. Ref: https://github.com/apache/flink-kubernetes-operator/blob/main/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java#L188-L199 -- This message was sent by Atlassian Jira (v8.20.10#820010)