fix log

dbsyncer-listener/src/main/java/org/dbsyncer/listener/AbstractExtractor.java

@@ -79,8 +79,8 @@ public abstract class AbstractExtractor implements Extractor {
     public void flushEvent() {
         // 20s内更新，执行写入
         if (watcher.getMetaUpdateTime() > Timestamp.valueOf(LocalDateTime.now().minusSeconds(FLUSH_DELAYED_SECONDS)).getTime()) {
-            logger.info("snapshot：{}", snapshot);
             if (!CollectionUtils.isEmpty(snapshot)) {
+                logger.info("snapshot：{}", snapshot);
                 watcher.flushEvent(snapshot);
             }
         }
@@ -88,8 +88,8 @@ public abstract class AbstractExtractor implements Extractor {
 
     @Override
     public void forceFlushEvent() {
-        logger.info("snapshot：{}", snapshot);
         if (!CollectionUtils.isEmpty(snapshot)) {
+            logger.info("snapshot：{}", snapshot);
             watcher.flushEvent(snapshot);
         }
     }

dbsyncer-listener/src/main/java/org/dbsyncer/listener/mysql/MySQLExtractor.java

@@ -14,7 +14,6 @@ import com.github.shyiko.mysql.binlog.network.ServerException;
 import net.sf.jsqlparser.JSQLParserException;
 import net.sf.jsqlparser.parser.CCJSqlParserUtil;
 import net.sf.jsqlparser.statement.alter.Alter;
-import org.dbsyncer.common.column.Lexer;
 import org.dbsyncer.common.event.ChangedOffset;
 import org.dbsyncer.common.event.DDLChangedEvent;
 import org.dbsyncer.common.event.RowChangedEvent;