From 62221a075a8e5f3dc049d00e92eace842af2c8d8 Mon Sep 17 00:00:00 2001 From: "zhicheng.zhang" Date: Thu, 29 May 2025 14:46:09 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=B7=E5=A4=96=E4=BB=BB=E5=8A=A1=E7=BC=93?= =?UTF-8?q?=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/bfd/mf/entity/mysql/SubjectTask.java | 1 + 1 file changed, 1 insertion(+) 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)) {