# Bulk Processor api not working

**URL:** https://discuss.elastic.co/t/bulk-processor-api-not-working/68674
**Category:** Elasticsearch
**Created:** [December 12, 2016, 8:09am UTC](https://discuss.elastic.co/t/bulk-processor-api-not-working/68674 "2016-12-12T08:09:11Z")
**Posts on this page:** 5
**Page:** 1

<div class="post-metadata">

### Author: ![nmalinip](https://avatars.discourse-cdn.com/v4/letter/n/ce73a5/32.png) [@nmalinip](https://discuss.elastic.co/u/nmalinip)
#### Post date: [December 12, 2016, 8:09am UTC](https://discuss.elastic.co/t/bulk-processor-api-not-working/68674/1 "2016-12-12T08:09:11Z")

</div>

HI,

I am trying to insert data into elasticsearch using java bulkprocessor api (in scala)...below is the code i am using...

```
val bulkProcessor = BulkProcessor.builder(esclient, new BulkProcessor.Listener() {
        @Override
        def beforeBulk(executionId: Long, request: BulkRequest) {
          log.info("Bulk Going to execute new bulk composed of {} actions" + request.numberOfActions());
        }

        @Override
        def afterBulk(executionId: Long, request: BulkRequest, response: BulkResponse) {
          log.info("Executed bulk composed of {} actions" + request.numberOfActions());
        }

        @Override
        def afterBulk(executionId: Long, request: BulkRequest, failure: Throwable) {
          log.info("Error executing bulk", failure);
        }
      }).setBulkActions(1000).setConcurrentRequests(1).setFlushInterval(TimeValue.timeValueMillis(5)).build();

```

Add 30-40 records

```
 val indexRequest =
          new IndexRequest(indexName, mappingName, tag.tagid)
            .source(builder);
        val updateRequest =
          new UpdateRequest(indexName, mappingName, tag.tagid) //.addScriptParam("newobj", builder).script("ctx.objectids+=newobj")
            .doc(builder)
            .upsert(indexRequest);

        bulkProcessor.add(updateRequest)

```

And then call the below method

```
bulkProcessor.awaitClose(10, TimeUnit.SECONDS)

```

But, i dont see the data indexed to elastic search. I only see the log from beforebulk. I dont see any log from afterbulk....

Am i missing anything?

Thanks,  
Malini

---

<div class="post-metadata">

### Author: ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)
#### Post date: [December 12, 2016, 9:28am UTC](https://discuss.elastic.co/t/bulk-processor-api-not-working/68674/2 "2016-12-12T09:28:15Z")

</div>

Please format your code using `</>` icon as explained in [this guide](https://discuss.elastic.co/t/about-the-elasticsearch-category/21). It will make your post more readable.

I edited your question.

Just a comment here. Don't send bulk requests every 5ms. It does not make sense.  
Use something like 5s, even more.

Not sure it would help.

The other part of the code looks ok.

---

<div class="post-metadata">

### Author: ![nmalinip](https://avatars.discourse-cdn.com/v4/letter/n/ce73a5/32.png) [@nmalinip](https://discuss.elastic.co/u/nmalinip)
#### Post date: [December 12, 2016, 5:28pm UTC](https://discuss.elastic.co/t/bulk-processor-api-not-working/68674/3 "2016-12-12T17:28:14Z")

</div>

Thanks David....i tried with 5s also, but no luck. I don't see data indexed to elastic search...

Thanks,  
Malini

---

<div class="post-metadata">

### Author: ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)
#### Post date: [December 13, 2016, 7:44am UTC](https://discuss.elastic.co/t/bulk-processor-api-not-working/68674/4 "2016-12-13T07:44:08Z")

</div>

Do you see any `Bulk Going to execute new bulk composed`?

---

<div class="post-metadata">

### Author: ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)
#### Post date: [January 10, 2017, 7:44am UTC](https://discuss.elastic.co/t/bulk-processor-api-not-working/68674/5 "2017-01-10T07:44:34Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.