|
@@ -50,7 +50,7 @@ public class SyncFlowPoolRecentTopVideoJob {
|
|
|
private List<Long> queryTopVideoIdsByLast6Hour(Integer topNum) {
|
|
|
String sql = "SELECT videoid FROM loghubods.flow_pool_video_info_per_hour " +
|
|
|
"WHERE dt = '" + odpsManager.getNowHour() + "' " +
|
|
|
- "ORDER BY 1d_return_cnt DESC LIMIT " + topNum + ";";
|
|
|
+ "ORDER BY 12hour_return_cnt DESC LIMIT " + topNum + ";";
|
|
|
List<Record> records = odpsManager.query(sql);
|
|
|
if (records == null || records.size() == 0) {
|
|
|
return null;
|