fix test cases

This commit is contained in:
Shinsuke Sugaya 2021-04-22 15:46:18 +09:00
parent 3e09e5b645
commit fa172652e0

View file

@ -206,8 +206,8 @@ public class CrawlTestBase extends ITBase {
final List<Map<String, Object>> logList = readLogItems("crawlinginfo");
final List<Map<String, Object>> resList = new ArrayList<>();
for (Map<String, Object> elem : logList) {
logger.info("config_id: {}, session_id: {}", configId, elem.containsKey("session_id"));
if (elem.containsKey("session_id") && elem.get("session_id").equals(configId)) {
logger.info("config_id: {}, session_id: {}", configId, elem.get("session_id"));
if (elem.containsKey("session_id") && elem.get("session_id").equals(configId.replace('-', '_'))) {
resList.add(elem);
}
}
@ -218,8 +218,8 @@ public class CrawlTestBase extends ITBase {
final List<Map<String, Object>> logList = readLogItems("failureurl");
final List<Map<String, Object>> resList = new ArrayList<>();
for (Map<String, Object> elem : logList) {
logger.info("config_id: {}, thread_name: {}", configId, elem.containsKey("thread_name"));
if (elem.containsKey("thread_name") && elem.get("thread_name").toString().startsWith("Crawler-" + configId)) {
logger.info("config_id: {}, thread_name: {}", configId, elem.get("thread_name"));
if (elem.containsKey("thread_name") && elem.get("thread_name").toString().startsWith("Crawler-" + configId.replace('-', '_'))) {
resList.add(elem);
}
}