if (closed) {
logger.info("Fs crawler is closed. Exiting");
return;
}
this.bulkProcessor = BulkProcessor.simpleBulkProcessor(client, settings.getElasticsearch().getBulkSize(),
<BUG>settings.getElasticsearch().getFlushInterval());
fsCrawlerThread = new Thread(new FSParser(settings), "fs-crawler");</BUG>
fsCrawlerThread.start();
}
public void close() throws InterruptedException, IOException {

if (closed) {
logger.info("Fs crawler is closed. Exiting");
return;
}
this.bulkProcessor = BulkProcessor.simpleBulkProcessor(client, settings.getElasticsearch().getBulkSize(),
settings.getElasticsearch().getFlushInterval(), settings.getElasticsearch().getPipeline());
fsCrawlerThread = new Thread(new FSParser(settings), "fs-crawler");
fsCrawlerThread.start();
}
public void close() throws InterruptedException, IOException {
