fix coll

dbsyncer-biz/src/main/java/org/dbsyncer/biz/impl/MappingServiceImpl.java

@@ -47,6 +47,7 @@ public class MappingServiceImpl extends BaseServiceImpl implements MappingServic
     @Override
     public String add(Map<String, String> params) {
         ConfigModel model = mappingChecker.checkAddConfigModel(params);
+        log((Mapping) model, LogType.MappingLog.INSERT);
         return manager.addMapping(model);
     }
 
@@ -57,6 +58,7 @@ public class MappingServiceImpl extends BaseServiceImpl implements MappingServic
         synchronized (LOCK) {
             assertRunning(mapping.getMetaId());
             ConfigModel model = mappingChecker.checkEditConfigModel(params);
+            log(mapping, LogType.MappingLog.UPDATE);
             return manager.editMapping(model);
         }
     }

dbsyncer-storage/src/main/java/org/dbsyncer/storage/support/DiskStorageServiceImpl.java

@@ -114,7 +114,6 @@ public class DiskStorageServiceImpl extends AbstractStorageService {
         Shard shard = map.get(collectionId);
         if (null != shard) {
             shard.deleteAll();
-            map.remove(collectionId);
         }
     }