private final ElasticsearchClient client;
private final Listener listener;
private BulkRequest bulkRequest;
private final ScheduledExecutorService executor;
private volatile boolean closed = false;
<BUG>private final AtomicLong executionIdGen = new AtomicLong();
private BulkProcessor(ElasticsearchClient client, Listener listener, int bulkActions, TimeValue flushInterval) {
</BUG>
this.bulkActions = bulkActions;
this.bulkRequest = new BulkRequest();

private final ElasticsearchClient client;
private final Listener listener;
private BulkRequest bulkRequest;
private final ScheduledExecutorService executor;
private volatile boolean closed = false;
private final AtomicLong executionIdGen = new AtomicLong();
private final String pipeline;
private BulkProcessor(ElasticsearchClient client, Listener listener, int bulkActions, TimeValue flushInterval, String pipeline) {
this.bulkActions = bulkActions;
this.bulkRequest = new BulkRequest();
