From fdd40224d5ec25ed2a264f2742feaed539498f42 Mon Sep 17 00:00:00 2001 From: agapple Date: Sat, 1 Apr 2017 22:20:00 +0800 Subject: [PATCH] fixed format & import --- .../manager/CanalInstanceWithManager.java | 4 +- .../parse/inbound/AbstractEventParser.java | 4 +- .../inbound/mysql/LocalBinlogEventParser.java | 2 +- .../index/AbstractLogPositionManager.java | 3 +- .../parse/index/CanalLogPositionManager.java | 3 +- .../index/FailbackLogPositionManager.java | 18 ++++--- .../index/FileMixedLogPositionManager.java | 51 ++++++++++--------- .../parse/index/MemoryLogPositionManager.java | 9 ++-- .../parse/index/MetaLogPositionManager.java | 18 +++---- .../parse/index/MixedLogPositionManager.java | 27 +++++----- .../index/PeriodMixedLogPositionManager.java | 36 +++++++------ .../index/ZooKeeperLogPositionManager.java | 8 +-- .../inbound/group/GroupEventPaserTest.java | 3 +- .../inbound/mysql/LocalBinlogDumpTest.java | 23 +++++---- .../mysql/LocalBinlogEventParserTest.java | 2 +- .../parse/inbound/mysql/MysqlDumpTest.java | 5 +- .../inbound/mysql/MysqlEventParserTest.java | 5 +- .../FileMixedLogPositionManagerTest.java | 8 ++- 18 files changed, 124 insertions(+), 105 deletions(-) diff --git a/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java b/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java index 2e8dbae9..842697ac 100644 --- a/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java +++ b/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java @@ -349,7 +349,9 @@ public class CanalInstanceWithManager extends AbstractCanalInstance { } else if (indexMode.isMixed()) { MemoryLogPositionManager memoryLogPositionManager = new MemoryLogPositionManager(); ZooKeeperLogPositionManager zooKeeperLogPositionManager = new ZooKeeperLogPositionManager(getZkclientx()); - logPositionManager = new PeriodMixedLogPositionManager(memoryLogPositionManager, zooKeeperLogPositionManager, 1000L); + logPositionManager = new PeriodMixedLogPositionManager(memoryLogPositionManager, + zooKeeperLogPositionManager, + 1000L); } else if (indexMode.isMeta()) { logPositionManager = new MetaLogPositionManager(metaManager); } else if (indexMode.isMemoryMetaFailback()) { diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java index 0fed2ef0..59fa2839 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java @@ -8,7 +8,6 @@ import java.util.TimerTask; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicLong; -import com.alibaba.otter.canal.parse.index.CanalLogPositionManager; import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.exception.ExceptionUtils; import org.apache.commons.lang.math.RandomUtils; @@ -23,6 +22,7 @@ import com.alibaba.otter.canal.parse.CanalEventParser; import com.alibaba.otter.canal.parse.exception.CanalParseException; import com.alibaba.otter.canal.parse.exception.TableIdNotFoundException; import com.alibaba.otter.canal.parse.inbound.EventTransactionBuffer.TransactionFlushCallback; +import com.alibaba.otter.canal.parse.index.CanalLogPositionManager; import com.alibaba.otter.canal.parse.support.AuthenticationInfo; import com.alibaba.otter.canal.protocol.CanalEntry; import com.alibaba.otter.canal.protocol.CanalEntry.Entry; @@ -44,7 +44,7 @@ public abstract class AbstractEventParser extends AbstractCanalLifeCycle protected final Logger logger = LoggerFactory.getLogger(this.getClass()); - protected CanalLogPositionManager logPositionManager = null; + protected CanalLogPositionManager logPositionManager = null; protected CanalEventSink> eventSink = null; protected CanalEventFilter eventFilter = null; protected CanalEventFilter eventBlackFilter = null; diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java index a0b32177..331b4d45 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java @@ -2,7 +2,6 @@ package com.alibaba.otter.canal.parse.inbound.mysql; import java.io.IOException; -import com.alibaba.otter.canal.parse.index.CanalLogPositionManager; import org.apache.commons.lang.StringUtils; import com.alibaba.otter.canal.parse.CanalEventParser; @@ -10,6 +9,7 @@ import com.alibaba.otter.canal.parse.exception.CanalParseException; import com.alibaba.otter.canal.parse.inbound.ErosaConnection; import com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert; import com.alibaba.otter.canal.parse.inbound.mysql.dbsync.TableMetaCache; +import com.alibaba.otter.canal.parse.index.CanalLogPositionManager; import com.alibaba.otter.canal.parse.support.AuthenticationInfo; import com.alibaba.otter.canal.protocol.position.EntryPosition; import com.alibaba.otter.canal.protocol.position.LogPosition; diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/index/AbstractLogPositionManager.java b/parse/src/main/java/com/alibaba/otter/canal/parse/index/AbstractLogPositionManager.java index 2c3c95da..95ee108e 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/index/AbstractLogPositionManager.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/index/AbstractLogPositionManager.java @@ -3,8 +3,7 @@ package com.alibaba.otter.canal.parse.index; import com.alibaba.otter.canal.common.AbstractCanalLifeCycle; /** - * Created by yinxiu on 17/3/17. - * Email: marklin.hz@gmail.com + * Created by yinxiu on 17/3/17. Email: marklin.hz@gmail.com */ public abstract class AbstractLogPositionManager extends AbstractCanalLifeCycle implements CanalLogPositionManager { } diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/index/CanalLogPositionManager.java b/parse/src/main/java/com/alibaba/otter/canal/parse/index/CanalLogPositionManager.java index 7947231d..2d7cd49f 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/index/CanalLogPositionManager.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/index/CanalLogPositionManager.java @@ -5,8 +5,7 @@ import com.alibaba.otter.canal.parse.exception.CanalParseException; import com.alibaba.otter.canal.protocol.position.LogPosition; /** - * Created by yinxiu on 17/3/17. - * Email: marklin.hz@gmail.com + * Created by yinxiu on 17/3/17. Email: marklin.hz@gmail.com */ public interface CanalLogPositionManager extends CanalLifeCycle { diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/index/FailbackLogPositionManager.java b/parse/src/main/java/com/alibaba/otter/canal/parse/index/FailbackLogPositionManager.java index fd2066f6..61e7d8f9 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/index/FailbackLogPositionManager.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/index/FailbackLogPositionManager.java @@ -1,14 +1,13 @@ package com.alibaba.otter.canal.parse.index; -import com.alibaba.otter.canal.parse.exception.CanalParseException; -import com.alibaba.otter.canal.protocol.position.LogPosition; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import com.alibaba.otter.canal.parse.exception.CanalParseException; +import com.alibaba.otter.canal.protocol.position.LogPosition; + /** - * Created by yinxiu on 17/3/18. - * Email: marklin.hz@gmail.com - * + * Created by yinxiu on 17/3/18. Email: marklin.hz@gmail.com * 实现基于failover查找的机制完成meta的操作 * * 
@@ -17,12 +16,12 @@ import org.slf4j.LoggerFactory;
  */
 public class FailbackLogPositionManager extends AbstractLogPositionManager {
 
-    private final static Logger logger = LoggerFactory.getLogger(FailbackLogPositionManager.class);
+    private final static Logger           logger = LoggerFactory.getLogger(FailbackLogPositionManager.class);
 
     private final CanalLogPositionManager primary;
     private final CanalLogPositionManager secondary;
 
-    public FailbackLogPositionManager(CanalLogPositionManager primary, CanalLogPositionManager secondary) {
+    public FailbackLogPositionManager(CanalLogPositionManager primary, CanalLogPositionManager secondary){
         if (primary == null) {
             throw new NullPointerException("nul primary LogPositionManager");
         }
@@ -74,7 +73,10 @@ public class FailbackLogPositionManager extends AbstractLogPositionManager {
         try {
             primary.persistLogPosition(destination, logPosition);
         } catch (CanalParseException e) {
-            logger.warn("persistLogPosition use primary log position manager exception. destination: {}, logPosition: {}", destination, logPosition, e);
+            logger.warn("persistLogPosition use primary log position manager exception. destination: {}, logPosition: {}",
+                destination,
+                logPosition,
+                e);
             secondary.persistLogPosition(destination, logPosition);
         }
     }
diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/index/FileMixedLogPositionManager.java b/parse/src/main/java/com/alibaba/otter/canal/parse/index/FileMixedLogPositionManager.java
index 072721af..ed0b9879 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/index/FileMixedLogPositionManager.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/index/FileMixedLogPositionManager.java
@@ -1,28 +1,32 @@
 package com.alibaba.otter.canal.parse.index;
 
+import java.io.File;
+import java.io.IOException;
+import java.nio.charset.Charset;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+import org.apache.commons.io.FileUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import com.alibaba.otter.canal.common.utils.JsonUtils;
 import com.alibaba.otter.canal.meta.exception.CanalMetaManagerException;
 import com.alibaba.otter.canal.parse.exception.CanalParseException;
 import com.alibaba.otter.canal.protocol.position.LogPosition;
 import com.google.common.base.Function;
 import com.google.common.collect.MigrateMap;
-import org.apache.commons.io.FileUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.File;
-import java.io.IOException;
-import java.nio.charset.Charset;
-import java.util.*;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
 
 /**
- * Created by yinxiu on 17/3/18.
- * Email: marklin.hz@gmail.com
- *
- * 基于文件刷新的log position实现
+ * Created by yinxiu on 17/3/18. Email: marklin.hz@gmail.com 基于文件刷新的log
+ * position实现
  *
  * 
  * 策略：
@@ -32,23 +36,24 @@ import java.util.concurrent.TimeUnit;
  */
 public class FileMixedLogPositionManager extends AbstractLogPositionManager {
 
-    private final static Logger logger = LoggerFactory.getLogger(FileMixedLogPositionManager.class);
-    private final static Charset charset = Charset.forName("UTF-8");
+    private final static Logger      logger       = LoggerFactory.getLogger(FileMixedLogPositionManager.class);
+    private final static Charset     charset      = Charset.forName("UTF-8");
 
-    private File dataDir;
+    private File                     dataDir;
 
-    private Map dataFileCaches;
+    private Map        dataFileCaches;
 
     private ScheduledExecutorService executorService;
 
-    private final LogPosition nullPosition = new LogPosition(){};
+    private final LogPosition        nullPosition = new LogPosition() {
+                                                  };
 
     private MemoryLogPositionManager memoryLogPositionManager;
 
-    private long period;
-    private Set persistTasks;
+    private long                     period;
+    private Set              persistTasks;
 
-    public FileMixedLogPositionManager(File dataDir, long period, MemoryLogPositionManager memoryLogPositionManager) {
+    public FileMixedLogPositionManager(File dataDir, long period, MemoryLogPositionManager memoryLogPositionManager){
         if (dataDir == null) {
             throw new NullPointerException("null dataDir");
         }
diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/index/MemoryLogPositionManager.java b/parse/src/main/java/com/alibaba/otter/canal/parse/index/MemoryLogPositionManager.java
index 9e20de5a..1658dd43 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/index/MemoryLogPositionManager.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/index/MemoryLogPositionManager.java
@@ -1,15 +1,14 @@
 package com.alibaba.otter.canal.parse.index;
 
+import java.util.Map;
+import java.util.Set;
+
 import com.alibaba.otter.canal.parse.exception.CanalParseException;
 import com.alibaba.otter.canal.protocol.position.LogPosition;
 import com.google.common.collect.MapMaker;
 
-import java.util.Map;
-import java.util.Set;
-
 /**
- * Created by yinxiu on 17/3/17.
- * Email: marklin.hz@gmail.com
+ * Created by yinxiu on 17/3/17. Email: marklin.hz@gmail.com
  */
 public class MemoryLogPositionManager extends AbstractLogPositionManager {
 
diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/index/MetaLogPositionManager.java b/parse/src/main/java/com/alibaba/otter/canal/parse/index/MetaLogPositionManager.java
index f3dd5479..35c3f252 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/index/MetaLogPositionManager.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/index/MetaLogPositionManager.java
@@ -1,27 +1,27 @@
 package com.alibaba.otter.canal.parse.index;
 
+import java.util.List;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.util.CollectionUtils;
+
 import com.alibaba.otter.canal.meta.CanalMetaManager;
 import com.alibaba.otter.canal.parse.exception.CanalParseException;
 import com.alibaba.otter.canal.protocol.ClientIdentity;
 import com.alibaba.otter.canal.protocol.position.LogPosition;
 import com.alibaba.otter.canal.store.helper.CanalEventUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.util.CollectionUtils;
-
-import java.util.List;
 
 /**
- * Created by yinxiu on 17/3/18.
- * Email: marklin.hz@gmail.com
+ * Created by yinxiu on 17/3/18. Email: marklin.hz@gmail.com
  */
 public class MetaLogPositionManager extends AbstractLogPositionManager {
 
-    private final static Logger logger = LoggerFactory.getLogger(MetaLogPositionManager.class);
+    private final static Logger    logger = LoggerFactory.getLogger(MetaLogPositionManager.class);
 
     private final CanalMetaManager metaManager;
 
-    public MetaLogPositionManager(CanalMetaManager metaManager) {
+    public MetaLogPositionManager(CanalMetaManager metaManager){
         if (metaManager == null) {
             throw new NullPointerException("null metaManager");
         }
diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/index/MixedLogPositionManager.java b/parse/src/main/java/com/alibaba/otter/canal/parse/index/MixedLogPositionManager.java
index 1e36c6e7..c21472ba 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/index/MixedLogPositionManager.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/index/MixedLogPositionManager.java
@@ -1,31 +1,29 @@
 package com.alibaba.otter.canal.parse.index;
 
-import com.alibaba.otter.canal.common.zookeeper.ZkClientx;
-import com.alibaba.otter.canal.parse.exception.CanalParseException;
-import com.alibaba.otter.canal.protocol.position.LogPosition;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.alibaba.otter.canal.common.zookeeper.ZkClientx;
+import com.alibaba.otter.canal.parse.exception.CanalParseException;
+import com.alibaba.otter.canal.protocol.position.LogPosition;
+
 /**
- * Created by yinxiu on 17/3/17.
- * Email: marklin.hz@gmail.com
- *
- * Memory first.
+ * Created by yinxiu on 17/3/17. Email: marklin.hz@gmail.com Memory first.
  * Asynchronous commit position info to ZK.
  */
 public class MixedLogPositionManager extends AbstractLogPositionManager {
 
-    private final Logger logger = LoggerFactory.getLogger(MixedLogPositionManager.class);
+    private final Logger                      logger = LoggerFactory.getLogger(MixedLogPositionManager.class);
 
-    private final MemoryLogPositionManager memoryLogPositionManager;
+    private final MemoryLogPositionManager    memoryLogPositionManager;
     private final ZooKeeperLogPositionManager zooKeeperLogPositionManager;
 
-    private final ExecutorService executor;
+    private final ExecutorService             executor;
 
-    public MixedLogPositionManager(ZkClientx zkClient) {
+    public MixedLogPositionManager(ZkClientx zkClient){
         if (zkClient == null) {
             throw new NullPointerException("null zkClient");
         }
@@ -71,6 +69,7 @@ public class MixedLogPositionManager extends AbstractLogPositionManager {
     public void persistLogPosition(final String destination, final LogPosition logPosition) throws CanalParseException {
         memoryLogPositionManager.persistLogPosition(destination, logPosition);
         executor.submit(new Runnable() {
+
             public void run() {
                 try {
                     zooKeeperLogPositionManager.persistLogPosition(destination, logPosition);
diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/index/PeriodMixedLogPositionManager.java b/parse/src/main/java/com/alibaba/otter/canal/parse/index/PeriodMixedLogPositionManager.java
index 63a1dae3..4a1e60c7 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/index/PeriodMixedLogPositionManager.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/index/PeriodMixedLogPositionManager.java
@@ -1,33 +1,39 @@
 package com.alibaba.otter.canal.parse.index;
 
-import com.alibaba.otter.canal.parse.exception.CanalParseException;
-import com.alibaba.otter.canal.protocol.position.LogPosition;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.alibaba.otter.canal.parse.exception.CanalParseException;
+import com.alibaba.otter.canal.protocol.position.LogPosition;
+
 /**
- * Created by yinxiu on 17/3/18.
- * Email: marklin.hz@gmail.com
+ * Created by yinxiu on 17/3/18. Email: marklin.hz@gmail.com
  */
 public class PeriodMixedLogPositionManager extends AbstractLogPositionManager {
 
-    private static final Logger logger = LoggerFactory.getLogger(PeriodMixedLogPositionManager.class);
+    private static final Logger         logger       = LoggerFactory.getLogger(PeriodMixedLogPositionManager.class);
 
-    private MemoryLogPositionManager memoryLogPositionManager;
+    private MemoryLogPositionManager    memoryLogPositionManager;
     private ZooKeeperLogPositionManager zooKeeperLogPositionManager;
-    private ScheduledExecutorService executorService;
+    private ScheduledExecutorService    executorService;
 
-    private long period;
-    private Set persistTasks;
+    private long                        period;
+    private Set                 persistTasks;
 
-    private final LogPosition nullPosition = new LogPosition(){};
+    private final LogPosition           nullPosition = new LogPosition() {
+                                                     };
 
-    public PeriodMixedLogPositionManager(MemoryLogPositionManager memoryLogPositionManager, ZooKeeperLogPositionManager zooKeeperLogPositionManager, long period) {
+    public PeriodMixedLogPositionManager(MemoryLogPositionManager memoryLogPositionManager,
+                                         ZooKeeperLogPositionManager zooKeeperLogPositionManager, long period){
         if (memoryLogPositionManager == null) {
             throw new NullPointerException("null memoryLogPositionManager");
         }
diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/index/ZooKeeperLogPositionManager.java b/parse/src/main/java/com/alibaba/otter/canal/parse/index/ZooKeeperLogPositionManager.java
index 116a45e6..65f0063d 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/index/ZooKeeperLogPositionManager.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/index/ZooKeeperLogPositionManager.java
@@ -1,21 +1,21 @@
 package com.alibaba.otter.canal.parse.index;
 
+import org.I0Itec.zkclient.exception.ZkNoNodeException;
+
 import com.alibaba.otter.canal.common.utils.JsonUtils;
 import com.alibaba.otter.canal.common.zookeeper.ZkClientx;
 import com.alibaba.otter.canal.common.zookeeper.ZookeeperPathUtils;
 import com.alibaba.otter.canal.parse.exception.CanalParseException;
 import com.alibaba.otter.canal.protocol.position.LogPosition;
-import org.I0Itec.zkclient.exception.ZkNoNodeException;
 
 /**
- * Created by yinxiu on 17/3/17.
- * Email: marklin.hz@gmail.com
+ * Created by yinxiu on 17/3/17. Email: marklin.hz@gmail.com
  */
 public class ZooKeeperLogPositionManager extends AbstractLogPositionManager {
 
     private final ZkClientx zkClientx;
 
-    public ZooKeeperLogPositionManager(ZkClientx zkClient) {
+    public ZooKeeperLogPositionManager(ZkClientx zkClient){
         if (zkClient == null) {
             throw new NullPointerException("null zkClient");
         }
diff --git a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/group/GroupEventPaserTest.java b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/group/GroupEventPaserTest.java
index dc3de102..3f6dff3c 100644
--- a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/group/GroupEventPaserTest.java
+++ b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/group/GroupEventPaserTest.java
@@ -2,13 +2,13 @@ package com.alibaba.otter.canal.parse.inbound.group;
 
 import java.net.InetSocketAddress;
 
-import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
 import org.junit.Test;
 
 import com.alibaba.otter.canal.parse.exception.CanalParseException;
 import com.alibaba.otter.canal.parse.inbound.AbstractBinlogParser;
 import com.alibaba.otter.canal.parse.inbound.BinlogParser;
 import com.alibaba.otter.canal.parse.inbound.mysql.MysqlEventParser;
+import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
 import com.alibaba.otter.canal.parse.support.AuthenticationInfo;
 import com.alibaba.otter.canal.protocol.CanalEntry.Entry;
 import com.alibaba.otter.canal.protocol.position.EntryPosition;
@@ -71,6 +71,7 @@ public class GroupEventPaserTest {
         mysqlEventPaser.setBinlogParser(buildParser(buildAuthentication()));
         mysqlEventPaser.setEventSink(new EntryEventSink());
         mysqlEventPaser.setLogPositionManager(new AbstractLogPositionManager() {
+
             @Override
             public LogPosition getLatestIndexBy(String destination) {
                 return null;
diff --git a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogDumpTest.java b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogDumpTest.java
index ffa8d11f..212f3af6 100644
--- a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogDumpTest.java
+++ b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogDumpTest.java
@@ -4,11 +4,11 @@ import java.net.InetSocketAddress;
 import java.nio.charset.Charset;
 import java.util.List;
 
-import com.alibaba.otter.canal.parse.exception.CanalParseException;
-import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
 import org.junit.Assert;
 import org.junit.Test;
 
+import com.alibaba.otter.canal.parse.exception.CanalParseException;
+import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
 import com.alibaba.otter.canal.parse.stub.AbstractCanalEventSinkTest;
 import com.alibaba.otter.canal.parse.support.AuthenticationInfo;
 import com.alibaba.otter.canal.protocol.CanalEntry.Column;
@@ -82,16 +82,17 @@ public class LocalBinlogDumpTest {
 
         });
         controller.setLogPositionManager(new AbstractLogPositionManager() {
-                    @Override
-                    public LogPosition getLatestIndexBy(String destination) {
-                        return null;
-                    }
 
-                    @Override
-                    public void persistLogPosition(String destination, LogPosition logPosition) throws CanalParseException {
-                        System.out.println(logPosition);
-                    }
-                });
+            @Override
+            public LogPosition getLatestIndexBy(String destination) {
+                return null;
+            }
+
+            @Override
+            public void persistLogPosition(String destination, LogPosition logPosition) throws CanalParseException {
+                System.out.println(logPosition);
+            }
+        });
 
         controller.start();
 
diff --git a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParserTest.java b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParserTest.java
index c17db374..d619916a 100644
--- a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParserTest.java
+++ b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParserTest.java
@@ -7,12 +7,12 @@ import java.util.Date;
 import java.util.List;
 import java.util.concurrent.atomic.AtomicLong;
 
-import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
 import com.alibaba.otter.canal.parse.helper.TimeoutChecker;
+import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
 import com.alibaba.otter.canal.parse.stub.AbstractCanalEventSinkTest;
 import com.alibaba.otter.canal.parse.support.AuthenticationInfo;
 import com.alibaba.otter.canal.protocol.CanalEntry.Entry;
diff --git a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlDumpTest.java b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlDumpTest.java
index 6c399e40..f7dab29a 100644
--- a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlDumpTest.java
+++ b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlDumpTest.java
@@ -4,11 +4,11 @@ import java.net.InetSocketAddress;
 import java.nio.charset.Charset;
 import java.util.List;
 
-import com.alibaba.otter.canal.parse.exception.CanalParseException;
-import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
 import org.junit.Assert;
 import org.junit.Test;
 
+import com.alibaba.otter.canal.parse.exception.CanalParseException;
+import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
 import com.alibaba.otter.canal.parse.stub.AbstractCanalEventSinkTest;
 import com.alibaba.otter.canal.parse.support.AuthenticationInfo;
 import com.alibaba.otter.canal.protocol.CanalEntry.Column;
@@ -85,6 +85,7 @@ public class MysqlDumpTest {
 
         });
         controller.setLogPositionManager(new AbstractLogPositionManager() {
+
             @Override
             public LogPosition getLatestIndexBy(String destination) {
                 return null;
diff --git a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParserTest.java b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParserTest.java
index 3eaacd82..82ecf4af 100644
--- a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParserTest.java
+++ b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParserTest.java
@@ -5,12 +5,12 @@ import java.util.Date;
 import java.util.List;
 import java.util.concurrent.atomic.AtomicLong;
 
-import com.alibaba.otter.canal.parse.exception.CanalParseException;
-import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
 import org.junit.Assert;
 import org.junit.Test;
 
+import com.alibaba.otter.canal.parse.exception.CanalParseException;
 import com.alibaba.otter.canal.parse.helper.TimeoutChecker;
+import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
 import com.alibaba.otter.canal.parse.stub.AbstractCanalEventSinkTest;
 import com.alibaba.otter.canal.parse.support.AuthenticationInfo;
 import com.alibaba.otter.canal.protocol.CanalEntry.Entry;
@@ -69,6 +69,7 @@ public class MysqlEventParserTest {
         });
 
         controller.setLogPositionManager(new AbstractLogPositionManager() {
+
             @Override
             public LogPosition getLatestIndexBy(String destination) {
                 return null;
diff --git a/parse/src/test/java/com/alibaba/otter/canal/parse/index/FileMixedLogPositionManagerTest.java b/parse/src/test/java/com/alibaba/otter/canal/parse/index/FileMixedLogPositionManagerTest.java
index 5d185648..e14d22d0 100644
--- a/parse/src/test/java/com/alibaba/otter/canal/parse/index/FileMixedLogPositionManagerTest.java
+++ b/parse/src/test/java/com/alibaba/otter/canal/parse/index/FileMixedLogPositionManagerTest.java
@@ -28,13 +28,17 @@ public class FileMixedLogPositionManagerTest extends AbstractLogPositionManagerT
     public void testAll() {
         MemoryLogPositionManager memoryLogPositionManager = new MemoryLogPositionManager();
 
-        FileMixedLogPositionManager logPositionManager = new FileMixedLogPositionManager(dataDir, 1000, memoryLogPositionManager);
+        FileMixedLogPositionManager logPositionManager = new FileMixedLogPositionManager(dataDir,
+            1000,
+            memoryLogPositionManager);
         logPositionManager.start();
 
         LogPosition position2 = doTest(logPositionManager);
         sleep(1500);
 
-        FileMixedLogPositionManager logPositionManager2 = new FileMixedLogPositionManager(dataDir, 1000, memoryLogPositionManager);
+        FileMixedLogPositionManager logPositionManager2 = new FileMixedLogPositionManager(dataDir,
+            1000,
+            memoryLogPositionManager);
         logPositionManager2.start();
 
         LogPosition getPosition2 = logPositionManager2.getLatestIndexBy(destination);