Showing
1 changed file
with
2 additions
and
2 deletions
@@ -43,12 +43,12 @@ public class SingleTask implements Runnable { | @@ -43,12 +43,12 @@ public class SingleTask implements Runnable { | ||
43 | } | 43 | } |
44 | } | 44 | } |
45 | //获取数据 | 45 | //获取数据 |
46 | - if("app_collect_sample".equals(taskModel.getDatabase())){ | 46 | + if("app_collect_sample".equals(taskModel.getDatabase())&&taskModel.getInfluxSql()!=null&&taskModel.getInfluxSql().indexOf("network_30s")>0){ |
47 | logger.error("begin execute app_collect_sample :" + taskModel.getInfluxSql()); | 47 | logger.error("begin execute app_collect_sample :" + taskModel.getInfluxSql()); |
48 | } | 48 | } |
49 | List<Map> resultList= getResultWithSql(taskModel,taskModel.getInfluxSql()); | 49 | List<Map> resultList= getResultWithSql(taskModel,taskModel.getInfluxSql()); |
50 | Map<String, List<List<Map<String, Object>>>> result = resultList.get(0); | 50 | Map<String, List<List<Map<String, Object>>>> result = resultList.get(0); |
51 | - if("app_collect_sample".equals(taskModel.getDatabase())){ | 51 | + if("app_collect_sample".equals(taskModel.getDatabase())&&taskModel.getInfluxSql()!=null&&taskModel.getInfluxSql().indexOf("network_30s")>0){ |
52 | logger.error("execute app_collect_sample resultList is :" + resultList); | 52 | logger.error("execute app_collect_sample resultList is :" + resultList); |
53 | logger.error("end execute app_collect_sample result is :" + result); | 53 | logger.error("end execute app_collect_sample result is :" + result); |
54 | } | 54 | } |
-
Please register or login to post a comment