nielsbasjes commented on a change in pull request #11245:
URL: https://github.com/apache/flink/pull/11245#discussion_r431844738
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java
##########
@@ -103,6 +103,15 @@ public static String getGitCommitTimeString() {
return getVersionsInstance().gitCommitTimeStr;
}
+ /**
+ * Returns the exact name of the Dockerimage for Flink that is needed
to run in.
+ *
+ * @return The "name:tag" of the Flink docker image.
+ */
+ public static String getFlinkDockerImageNameAndTag() {
Review comment:
Understood. I've moved it to the simplest implementation I can think of
(i.e. only in the KubernetesConfigOptions ). If the real usecase appears I
expect it to be more clear what the appropriate "central" location should be.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
