|
|
@@ -60,8 +60,8 @@ public class RickVideoCacheJob {
|
|
|
List<Record> records = odpsManager.tableTunnelQuery(PROJECT, riskVideoTable, "dt=" + dt);
|
|
|
if (Objects.isNull(records) || records.isEmpty()) {
|
|
|
XxlJobLogger.log("records is empty");
|
|
|
- //无数据 清空缓存
|
|
|
- redisTemplate.delete(RedisKeyConstants.Recommend.WECHAT_RISK_VIDEO_CACHE_KEY);
|
|
|
+ //无数据 暂不清空缓存 避免大数据产出数据失败
|
|
|
+// redisTemplate.delete(RedisKeyConstants.Recommend.WECHAT_RISK_VIDEO_CACHE_KEY);
|
|
|
return ReturnT.SUCCESS;
|
|
|
}
|
|
|
XxlJobLogger.log("records size = {}", records.size());
|
|
|
@@ -79,7 +79,8 @@ public class RickVideoCacheJob {
|
|
|
}
|
|
|
XxlJobLogger.log("videoSet size = {}", videoSet.size());
|
|
|
if (videoSet.isEmpty()) {
|
|
|
- redisTemplate.delete(RedisKeyConstants.Recommend.WECHAT_RISK_VIDEO_CACHE_KEY);
|
|
|
+ //暂不清空缓存 避免大数据产出数据失败
|
|
|
+// redisTemplate.delete(RedisKeyConstants.Recommend.WECHAT_RISK_VIDEO_CACHE_KEY);
|
|
|
return ReturnT.SUCCESS;
|
|
|
}
|
|
|
//需要保证原子性；由于数据量可能较大，不使用lua，采用临时key重命名方式；使用hashtag，保证rename在一个slot
|
supeng