File tree Expand file tree Collapse file tree 3 files changed +6
-3
lines changed
flink-kubernetes-operator/src/main
java/org/apache/flink/kubernetes/operator Expand file tree Collapse file tree 3 files changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -113,6 +113,9 @@ private void overrideOperatorConfigs(ConfigurationServiceOverrider overrider) {
113
113
} else {
114
114
LOG .info ("Configuring operator with {} reconciliation threads." , parallelism );
115
115
overrider .withConcurrentReconciliationThreads (parallelism );
116
+ // feat: separate executor service for workflow
117
+ // https://github.com/java-operator-sdk/java-operator-sdk/pull/1371
118
+ overrider .withExecutorService (Executors .newFixedThreadPool (parallelism ));
116
119
}
117
120
if (configManager .getOperatorConfiguration ().isJosdkMetricsEnabled ()) {
118
121
overrider .withMetrics (new OperatorJosdkMetrics (metricGroup , configManager ));
Original file line number Diff line number Diff line change @@ -43,8 +43,8 @@ This project bundles the following dependencies under the Apache Software Licens
43
43
- io.fabric8:kubernetes-model-scheduling:5.12.3
44
44
- io.fabric8:kubernetes-model-storageclass:5.12.3
45
45
- io.fabric8:zjsonpatch:0.3.0
46
- - io.javaoperatorsdk:operator-framework-core:3.1 .1
47
- - io.javaoperatorsdk:operator-framework:3.1 .1
46
+ - io.javaoperatorsdk:operator-framework-core:3.2 .1
47
+ - io.javaoperatorsdk:operator-framework:3.2 .1
48
48
- org.apache.commons:commons-compress:1.21
49
49
- org.apache.commons:commons-lang3:3.12.0
50
50
- org.apache.commons:commons-math3:3.6.1
Original file line number Diff line number Diff line change @@ -68,7 +68,7 @@ under the License.
68
68
<maven-resources-plugin .version>3.2.0</maven-resources-plugin .version>
69
69
<git-commit-id-maven-plugin .version>5.0.0</git-commit-id-maven-plugin .version>
70
70
71
- <operator .sdk.version>3.1 .1</operator .sdk.version>
71
+ <operator .sdk.version>3.2 .1</operator .sdk.version>
72
72
<operator .sdk.admission-controller.version>0.2.0</operator .sdk.admission-controller.version>
73
73
74
74
<fabric8 .version>5.12.3</fabric8 .version>
You can’t perform that action at this time.
0 commit comments