限制最大量

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/xxl/RickVideoCacheJob.java

@@ -48,7 +48,7 @@ public class RickVideoCacheJob {
         XxlJobLogger.log("updateRiskVideoCacheHandler start...");
         try {
             //1. 从大数据读取数据 最大不超过10万条
-            String sql = "SELECT videoid FROM " + riskVideoTable + " WHERE dt = MAX_PT('" + riskVideoTable + "');";
+            String sql = "SELECT videoid FROM " + riskVideoTable + " WHERE dt = MAX_PT('" + riskVideoTable + "') limit 100000;";
             List<Record> records = odpsManager.query(sql);
             if (Objects.isNull(records) || records.isEmpty()) {
                 XxlJobLogger.log("records is empty");