|
@@ -356,7 +356,7 @@ public class XxlJobService {
|
|
|
break;
|
|
|
}
|
|
|
String pt = DateUtils.getDateString(startTime.getTime());
|
|
|
- String sql = String.format("SELECT count(*) FROM push_message_callback WHERE pt = %s", pt);
|
|
|
+ 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);
|