logger.debug("FS crawler connected to an elasticsearch [{}] node.", version);
elasticsearchVersion = extractMajorVersionNumber(version);
} catch (Exception e) {
logger.warn("failed to create index [{}], disabling crawler...", settings.getElasticsearch().getIndex());
throw e;
<BUG>}
try {</BUG>
Path jobMappingDir = config.resolve(settings.getName()).resolve("_mappings");
if (!settings.getFs().isJsonSupport() && !settings.getFs().isXmlSupport()) {
String mapping = FsCrawlerUtil.readMapping(jobMappingDir, config, elasticsearchVersion, FsCrawlerUtil.INDEX_TYPE_DOC);

logger.debug("FS crawler connected to an elasticsearch [{}] node.", version);
elasticsearchVersion = extractMajorVersionNumber(version);
} catch (Exception e) {
logger.warn("failed to create index [{}], disabling crawler...", settings.getElasticsearch().getIndex());
throw e;
}
if (settings.getElasticsearch().getPipeline() != null && !client.isIngestSupported()) {
throw new RuntimeException("You defined pipeline:" + settings.getElasticsearch().getPipeline() +
", but your elasticsearch cluster does not support this feature.");
}
try {
Path jobMappingDir = config.resolve(settings.getName()).resolve("_mappings");
if (!settings.getFs().isJsonSupport() && !settings.getFs().isXmlSupport()) {
String mapping = FsCrawlerUtil.readMapping(jobMappingDir, config, elasticsearchVersion, FsCrawlerUtil.INDEX_TYPE_DOC);
