Skip to content

Commit e1047ca

Browse files
authored
fix: set hash map concurrent in workflows (#1870)
1 parent a9ecc73 commit e1047ca

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/workflow/AbstractWorkflowExecutor.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package io.javaoperatorsdk.operator.processing.dependent.workflow;
22

3-
import java.util.HashMap;
43
import java.util.Map;
54
import java.util.Map.Entry;
65
import java.util.Optional;
@@ -25,7 +24,7 @@ public abstract class AbstractWorkflowExecutor<P extends HasMetadata> {
2524
* Covers both deleted and reconciled
2625
*/
2726
private final Set<DependentResourceNode> alreadyVisited = ConcurrentHashMap.newKeySet();
28-
private final Map<DependentResourceNode, Future<?>> actualExecutions = new HashMap<>();
27+
private final Map<DependentResourceNode, Future<?>> actualExecutions = new ConcurrentHashMap<>();
2928
private final Map<DependentResourceNode, Exception> exceptionsDuringExecution =
3029
new ConcurrentHashMap<>();
3130

0 commit comments

Comments
 (0)