Skip to content

Commit 6783e26

Browse files
gaoyan1998aiwenmoCopilot
authored
[Bug] Fix operator submit bug (#4402)
Co-authored-by: Wink <809097465@qq.com> Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
1 parent 8a860cf commit 6783e26

2 files changed

Lines changed: 7 additions & 0 deletions

File tree

dinky-gateway/src/main/java/org/dinky/gateway/AbstractGateway.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,10 @@ public void setGatewayConfig(GatewayConfig config) {
8989

9090
protected abstract void init();
9191

92+
protected boolean removeConfigParas(ConfigOption<String> configOption) {
93+
return this.configuration.removeConfig(configOption);
94+
}
95+
9296
protected void addConfigParas(Map<String, String> configMap) {
9397
if (Asserts.isNotNull(configMap)) {
9498
configMap.entrySet().stream()

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,9 @@ public abstract class KubernetesOperatorGateway extends KubernetesGateway {
7272
public void init() {
7373
kubernetesConfiguration = config.getKubernetesConfig().getConfiguration();
7474
initConfig();
75+
// Operator does not need this config; it should be removed to avoid exceptions.
76+
this.removeConfigParas(KubernetesConfigOptions.KUBE_CONFIG_FILE);
77+
7578
initBase();
7679
initMetadata();
7780
initSpec();

0 commit comments

Comments
 (0)