Out of memory after bulk rejection

Elastic Stack Elasticsearch
1

I have a setup in which I am sending request to ES (5.6.4) using bulkProcessor.

The problem is that the requests sent to es are more than it can process and the queue is getting full.

The rejected requests are still in my program's memory and it is creating OOM exception in my server.

But in other scenario, if I send all the requests with the same index name(just a test), then everything is working fine.

My question is, where can I check for the rejected request?(not coming in afterbulk)
And how do I clear it from the memory?

2

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