diff --git a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java index d4a971248d..9650945e8c 100644 --- a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java +++ b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java @@ -113,6 +113,9 @@ private void overrideOperatorConfigs(ConfigurationServiceOverrider overrider) { } else { LOG.info("Configuring operator with {} reconciliation threads.", parallelism); overrider.withConcurrentReconciliationThreads(parallelism); + // feat: separate executor service for workflow + // https://github.com/java-operator-sdk/java-operator-sdk/pull/1371 + overrider.withExecutorService(Executors.newFixedThreadPool(parallelism)); } if (configManager.getOperatorConfiguration().isJosdkMetricsEnabled()) { overrider.withMetrics(new OperatorJosdkMetrics(metricGroup, configManager)); diff --git a/flink-kubernetes-operator/src/main/resources/META-INF/NOTICE b/flink-kubernetes-operator/src/main/resources/META-INF/NOTICE index 3e17537ffa..f7b74ff68b 100644 --- a/flink-kubernetes-operator/src/main/resources/META-INF/NOTICE +++ b/flink-kubernetes-operator/src/main/resources/META-INF/NOTICE @@ -43,8 +43,8 @@ This project bundles the following dependencies under the Apache Software Licens - io.fabric8:kubernetes-model-scheduling:5.12.3 - io.fabric8:kubernetes-model-storageclass:5.12.3 - io.fabric8:zjsonpatch:0.3.0 -- io.javaoperatorsdk:operator-framework-core:3.1.1 -- io.javaoperatorsdk:operator-framework:3.1.1 +- io.javaoperatorsdk:operator-framework-core:3.2.1 +- io.javaoperatorsdk:operator-framework:3.2.1 - org.apache.commons:commons-compress:1.21 - org.apache.commons:commons-lang3:3.12.0 - org.apache.commons:commons-math3:3.6.1 diff --git a/pom.xml b/pom.xml index eb15277462..3223427089 100644 --- a/pom.xml +++ b/pom.xml @@ -68,7 +68,7 @@ under the License. 3.2.0 5.0.0 - 3.1.1 + 3.2.1 0.2.0 5.12.3