update

dbsyncer-listener/src/main/java/org/dbsyncer/listener/extractor/MysqlExtractor.java

@@ -70,7 +70,6 @@ public class MysqlExtractor extends DefaultExtractor {
     @Override
     public void close() {
         try {
-            clearAllListener();
             client.stopQuietly();
         } catch (Exception e) {
             logger.error("关闭失败:{}", e.getMessage());

dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/impl/IncrementPuller.java

@@ -75,8 +75,9 @@ public class IncrementPuller extends AbstractPuller {
 
     @Override
     public void close(String metaId) {
-        Extractor extractor = map.get(metaId);
+        DefaultExtractor extractor = map.get(metaId);
         if (null != extractor) {
+            extractor.clearAllListener();
             extractor.close();
             finished(metaId);
         }