fix #2600 add getAccessResultData

This commit is contained in:
Shinsuke Sugaya 2021-10-19 21:59:04 +09:00
parent 8567d63555
commit 7b1dbe0f89

View file

@ -339,7 +339,7 @@ public class IndexUpdater extends Thread {
}
final long startTime = System.currentTimeMillis();
final AccessResultData<?> accessResultData = accessResult.getAccessResultData();
final AccessResultData<?> accessResultData = getAccessResultData(accessResult);
if (accessResultData != null) {
accessResult.setAccessResultData(null);
try {
@ -394,6 +394,15 @@ public class IndexUpdater extends Thread {
}
}
private AccessResultData<?> getAccessResultData(final EsAccessResult accessResult) {
try {
return accessResult.getAccessResultData();
} catch (Exception e) {
logger.warn("Failed to get data from {}", accessResult.getUrl(), e);
}
return null;
}
protected Map<String, Object> ingest(final AccessResult<String> accessResult, final Map<String, Object> map) {
if (ingestFactory == null) {
return map;