소스 검색

增加删除回调消息定时任务

xueyiming 1 년 전
부모
커밋
92bcf0da7a
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/XxlJobService.java

+ 1 - 1
long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/XxlJobService.java

@@ -359,7 +359,7 @@ public class XxlJobService {
             String sql = String.format("SELECT count(*) FROM push_message_callback WHERE pt = %s;", pt);
             List<Record> recordList = odpsManager.query(sql);
             if (CollectionUtil.isEmpty(recordList)) {
-                LarkRobotUtil.sendMessage("查询hive失败" + pt);
+                LarkRobotUtil.sendMessage("查询hive失败" + pt);
                 return ReturnT.FAIL;
             }
             Long hiveCount = recordList.get(0).getBigint(0);