#1978 modify pipeline

This commit is contained in:
Shinsuke Sugaya 2019-01-25 22:56:06 +09:00
parent e85f00d568
commit 7efbd01096

View file

@ -125,8 +125,11 @@ public class CrawlingConfigHelper {
if (config == null) {
return OptionalThing.empty();
}
final Map<String, String> paramMap = config.getConfigParameterMap(ConfigName.CONFIG);
return OptionalThing.of(paramMap.get("pipeline"));
final String pipeline = config.getConfigParameterMap(ConfigName.CONFIG).get("pipeline");
if (StringUtil.isBlank(pipeline)) {
return OptionalThing.empty();
}
return OptionalThing.of(pipeline);
}
public void refresh() {