diff --git a/cl_stream_datasave/src/main/java/com/bfd/mf/entity/mysql/SubjectTask.java b/cl_stream_datasave/src/main/java/com/bfd/mf/entity/mysql/SubjectTask.java index f20ab8b..0b91dc0 100644 --- a/cl_stream_datasave/src/main/java/com/bfd/mf/entity/mysql/SubjectTask.java +++ b/cl_stream_datasave/src/main/java/com/bfd/mf/entity/mysql/SubjectTask.java @@ -454,6 +454,7 @@ public class SubjectTask implements Runnable { private boolean disposeCrawldataflag(String crawldataflag) { try{ + if (RedisUtil.exists(crawldataflag, 9)) { // 先去 redis中查询是否存在,不存直接忽略 String value = RedisUtil.get(crawldataflag,9); if(null != value && !("").equals(value)) {