File tree Expand file tree Collapse file tree
dinky-gateway/src/main/java/org/dinky/gateway/kubernetes/operator Expand file tree Collapse file tree Original file line number Diff line number Diff line change 3636import org .apache .commons .collections .MapUtils ;
3737import org .apache .commons .lang3 .StringUtils ;
3838import org .apache .flink .configuration .CoreOptions ;
39+ import org .apache .flink .configuration .DeploymentOptionsInternal ;
3940import org .apache .flink .configuration .HighAvailabilityOptions ;
4041import org .apache .flink .configuration .JobManagerOptions ;
4142import org .apache .flink .configuration .TaskManagerOptions ;
@@ -205,8 +206,8 @@ private void initResource() {
205206 }
206207
207208 // flink config defined key
208- private final List <String > flinkConfigDefinedByFlink =
209- Lists . newArrayList ( "kubernetes.namespace" , "kubernetes.cluster-id" );
209+ private final List <String > flinkConfigDefinedByFlink = Lists . newArrayList (
210+ "kubernetes.namespace" , "kubernetes.cluster-id" , DeploymentOptionsInternal . CONF_DIR . key () );
210211
211212 private void initSpec () {
212213 String flinkVersion = flinkConfig .getFlinkVersion ();
You can’t perform that action at this time.
0 commit comments