Index is manually refreshed by BulkIndexer
*/
public class BulkIndexer implements Startable {
private static final Logger LOGGER = Loggers.get(BulkIndexer.class);
- private static final long FLUSH_BYTE_SIZE = new ByteSizeValue(5, ByteSizeUnit.MB).bytes();
+ private static final long FLUSH_BYTE_SIZE = new ByteSizeValue(2, ByteSizeUnit.MB).bytes();
private static final String REFRESH_INTERVAL_SETTING = "index.refresh_interval";
private static final String ALREADY_STARTED_MESSAGE = "Bulk indexing is already started";
public void define(IndexDefinitionContext context) {
NewIndex index = context.create(INDEX);
+ // refresh is always handled by SourceLineIndexer
+ index.getSettings().put("index.refresh_interval", "-1");
+
// shards
boolean clusterMode = settings.getBoolean(ProcessConstants.CLUSTER_ACTIVATE);
if (clusterMode) {