[FLINK-28574] Bump the JOSDK version to 3.2.1
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 d4a9712..9650945 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 @@
} 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 3e17537..f7b74ff 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 @@
- 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 eb15277..3223427 100644
--- a/pom.xml
+++ b/pom.xml
@@ -68,7 +68,7 @@
<maven-resources-plugin.version>3.2.0</maven-resources-plugin.version>
<git-commit-id-maven-plugin.version>5.0.0</git-commit-id-maven-plugin.version>
- <operator.sdk.version>3.1.1</operator.sdk.version>
+ <operator.sdk.version>3.2.1</operator.sdk.version>
<operator.sdk.admission-controller.version>0.2.0</operator.sdk.admission-controller.version>
<fabric8.version>5.12.3</fabric8.version>
