Skip to content

Commit 93c2673

Browse files
authored
[Bug][k8s-operator] Remove CONF_DIR from FlinkConfiguration (#4419)
1 parent 0e32650 commit 93c2673

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

dinky-gateway/src/main/java/org/dinky/gateway/kubernetes/operator/KubernetesOperatorGateway.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,7 @@
3838
import org.apache.commons.collections.MapUtils;
3939
import org.apache.commons.lang3.StringUtils;
4040
import org.apache.flink.configuration.CoreOptions;
41+
import org.apache.flink.configuration.DeploymentOptionsInternal;
4142
import org.apache.flink.configuration.HighAvailabilityOptions;
4243
import org.apache.flink.configuration.JobManagerOptions;
4344
import org.apache.flink.configuration.TaskManagerOptions;
@@ -207,8 +208,8 @@ private void initResource() {
207208
}
208209

209210
// flink config defined key
210-
private final List<String> flinkConfigDefinedByFlink =
211-
Lists.newArrayList("kubernetes.namespace", "kubernetes.cluster-id");
211+
private final List<String> flinkConfigDefinedByFlink = Lists.newArrayList(
212+
"kubernetes.namespace", "kubernetes.cluster-id", DeploymentOptionsInternal.CONF_DIR.key());
212213

213214
private void initSpec() {
214215
String flinkVersion = flinkConfig.getFlinkVersion();

0 commit comments

Comments
 (0)