mcy 6 years ago
parent
commit
f6d03bcb37

+ 3 - 4
client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/ESAdapter.java

@@ -230,6 +230,9 @@ public class ESAdapter implements OuterAdapter {
 
 
     @Override
     @Override
     public void destroy() {
     public void destroy() {
+        if (esConfigMonitor != null) {
+            esConfigMonitor.destroy();
+        }
         if (transportClient != null) {
         if (transportClient != null) {
             transportClient.close();
             transportClient.close();
         }
         }
@@ -237,10 +240,6 @@ public class ESAdapter implements OuterAdapter {
 
 
     @Override
     @Override
     public String getDestination(String task) {
     public String getDestination(String task) {
-        if (esConfigMonitor != null) {
-            esConfigMonitor.destroy();
-        }
-
         ESSyncConfig config = esSyncConfig.get(task);
         ESSyncConfig config = esSyncConfig.get(task);
         if (config != null) {
         if (config != null) {
             return config.getDestination();
             return config.getDestination();