commit

src/main/java/com/jz/dmp/modules/service/impl/DmpRealtimeSyncInfoServiceImpl.java

@@ -1056,12 +1056,6 @@ public class DmpRealtimeSyncInfoServiceImpl implements DmpRealtimeSyncInfoServic
         }
 
         Map map = JSONObject.parseObject(respData);
-        /*List<Map> tasks = (List<Map>) map.get("tasks");
-        if (tasks.size() > 0 && null != tasks) {
-            String tasksStatus = (String) tasks.get(0).get("state");
-            logger.info("response tasks status{}" + tasksStatus);
-            return tasksStatus;
-        }*/
         Map connector = (Map) map.get("connector");
         if (null != connector && connector.size() > 0) {
             if (!connector.containsKey("state")) {
@@ -1071,7 +1065,7 @@ public class DmpRealtimeSyncInfoServiceImpl implements DmpRealtimeSyncInfoServic
             logger.info("response connector status{}" + status);
         }
 
-        if (StringUtils.isNotEmpty((String) params.get("id")) && StringUtils.isEmpty(status)) {
+        if (StringUtils.isNotEmpty((String) params.get("id"))) {
             Thread thread = new Thread(new Runnable() {
                 @Override
                 public void run() {