FuyaoLi2017 commented on code in PR #202:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/202#discussion_r872873594
##########
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java:
##########
@@ -133,6 +135,19 @@ public Configuration getObserveConfig(FlinkDeployment
deployment) {
return getConfig(deployment.getMetadata(),
ReconciliationUtils.getDeployedSpec(deployment));
}
+ public Configuration getSessionJobObserveConfig(
+ FlinkDeployment deployment, FlinkSessionJob flinkSessionJob) {
+ Configuration sessionJobConfig = getObserveConfig(deployment);
+
+ // merge session job specific config
+ Map<String, String> sessionJobFlinkConfiguration =
+ flinkSessionJob.getSpec().getFlinkConfiguration();
+ if (sessionJobFlinkConfiguration != null &&
!sessionJobFlinkConfiguration.isEmpty()) {
+ sessionJobFlinkConfiguration.forEach(sessionJobConfig::setString);
Review Comment:
I guess the logic would be more straight forward if this config in
sessionJob directly overrides the parent config.
If we do the merging work. Then a user will need to check two CRs instead of
one to determine what are the actual headers that is applied during jar
fetching during debugging. It could be a little bit confusing.
--
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.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
