update breakpoint name

Author: pingxingshikong

syncer-transmission/src/main/java/syncer/transmission/checkpoint/breakpoint/BreakPoint.java

@@ -69,7 +69,7 @@ private OffSetEntity getTargetPointOffset(String taskId, String host, int port,
 
                 return null;
             }
-            String hostName = sourceHost + ":" + sourceHost;
+            String hostName = sourceHost + ":" + sourcePort;
             String offsetName = hostName + "-offset";
             String runidName = hostName + "-runid";
             String versionName = hostName + "-version";

syncer-transmission/src/main/java/syncer/transmission/client/impl/JedisMultiExecPipeLineClient.java

@@ -197,7 +197,7 @@ public void updateLastReplidAndOffset(String replid, long offset){
     void addCheckPoint(){
         //checkpoint
         Map<String,String>chekpoint=new HashMap<>();
-        String hostName=sourceHost+":"+sourceHost;
+        String hostName=sourceHost+":"+sourcePort;
         chekpoint.put(hostName+"-offset", String.valueOf(lastOffset));
         chekpoint.put(hostName+"-runid", lastReplid);
         chekpoint.put(hostName+"-version", CHECKPOINT_VERSION);
@@ -1205,23 +1205,19 @@ void commitCompensator(List<Object> resultList) {
                 EventEntity eventEntity= kvPersistence.getKey(i);
                 byte[] cmd = eventEntity.getCmd();
                 String key = eventEntity.getStringKey();
-
                 if (!commandCompensatorUtils.isCommandSuccess(data, cmd, taskId, key)) {
                     log.error("Command[{}],KEY[{}]进入补偿机制：[{}] : RESPONSE[{}]->String[{}]", Strings.byteToString(cmd), eventEntity.getStringKey(), JSON.toJSONString(data), data, compensatorUtils.getRes(data));
                     newKvPersistence.addKey(eventEntity);
                     insertCompensationCommand(eventEntity);
                 }
             }
-
             kvPersistence.clear();
             resultList.clear();
             date = new Date();
             commandNums.set(0);
             newKvPersistence.getKeys().stream().forEach(data -> {
                 compensator(data);
             });
-
-
             newKvPersistence.clear();
         } finally {
 

syncer-transmission/src/main/java/syncer/transmission/client/impl/sentinel/JedisSentinelMultiExecPipeLineClient.java

@@ -200,7 +200,7 @@ public void updateLastReplidAndOffset(String replid, long offset){
     void addCheckPoint(){
         //checkpoint
         Map<String,String>chekpoint=new HashMap<>();
-        String hostName=sourceHost+":"+sourceHost;
+        String hostName=sourceHost+":"+sourcePort;
         chekpoint.put(hostName+"-offset", String.valueOf(lastOffset));
         chekpoint.put(hostName+"-runid", lastReplid);
         chekpoint.put(hostName+"-version", CHECKPOINT_VERSION);