swap close order

apache · Nov 18, 2023 · 8dc9cf3 · 8dc9cf3
1 parent e82c21b
commit 8dc9cf3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...java/org/apache/flink/connector/kafka/source/enumerator/DynamicKafkaSourceEnumerator.java b/...java/org/apache/flink/connector/kafka/source/enumerator/DynamicKafkaSourceEnumerator.java
@@ -408,8 +408,8 @@ private void startAllEnumerators() {
                             kafkaClusterId,
                             e);
                     try {
-                        clusterEnumeratorMap.remove(kafkaClusterId).close();
                         clusterEnumContextMap.remove(kafkaClusterId).close();
+                        clusterEnumeratorMap.remove(kafkaClusterId).close();
                     } catch (Exception ex) {
                         // closing enumerator throws an exception, let error propagate and restart
                         // the job