# Bulk Request java.lang.InterruptedException concurrency issue

**URL:** <https://discuss.elastic.co/t/bulk-request-java-lang-interruptedexception-concurrency-issue/253850>\
**Category:** Elasticsearch\
**Created:** [October 30, 2020, 5:54pm UTC](https://discuss.elastic.co/t/bulk-request-java-lang-interruptedexception-concurrency-issue/253850 "2020-10-30T17:54:13Z")\
**Posts on this page:** 6\
**Page:** 1

<div class="post-metadata">

**Author:** ![rex-remind](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/rex-remind/32/46637_2.png) [@rex-remind](https://discuss.elastic.co/u/rex-remind)\
**Post date:** [October 30, 2020, 5:54pm UTC](https://discuss.elastic.co/t/bulk-request-java-lang-interruptedexception-concurrency-issue/253850/1 "2020-10-30T17:54:13Z")

</div>

Hello,

Context:  
We have a simple Flink job (v1.11.2 in Scala) from Kafka to ES using the Table api with just 2 joins before writing to ES. It uses the [Flink Elasticsearch Connector](https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/elasticsearch.html) which under the hood uses the [Java ES SDK BulkProcessor](https://github.com/elastic/elasticsearch/blob/master/server/src/main/java/org/elasticsearch/action/bulk/BulkProcessor.java).

Error:  
We continuously receive these `java.lang.InterruptedException` errors killing our job which is a showstopper for us. Exception always seems to either get thrown at `latch.await()` [[link](https://github.com/elastic/elasticsearch/blob/0ed5174cb870c4d6be23c7820513cbdb3cf0ecb8/server/src/main/java/org/elasticsearch/action/bulk/BulkRequestHandler.java#L78)] or at `semaphore.aquire()` [[link](https://github.com/elastic/elasticsearch/blob/0ed5174cb870c4d6be23c7820513cbdb3cf0ecb8/server/src/main/java/org/elasticsearch/action/bulk/BulkRequestHandler.java#L59)]. Retrying usually succeeds and then crashes on a later document. This indicates to us that it's some sort of concurrency issue. Flink uses Elasticsearch SDK version 7.5.1. We tried manually replacing with 7.9 but received the same issue.

We dug in a bit more and found [https://github.com/elastic/elasticsearch/issues/36782](https://github.com/elastic/elasticsearch/issues/36782) which seems to indicate that this was failing tests at one point and then stopped happening.

We really need help getting past this error. An error stack trace will copied below. We have exceeded char limit.

Thanks

---

<div class="post-metadata">

**Author:** ![rex-remind](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/rex-remind/32/46637_2.png) [@rex-remind](https://discuss.elastic.co/u/rex-remind)\
**Post date:** [October 30, 2020, 5:54pm UTC](https://discuss.elastic.co/t/bulk-request-java-lang-interruptedexception-concurrency-issue/253850/2 "2020-10-30T17:54:59Z")

</div>

```auto
    2020.10.27 23:52:01 INFO 23:52:01,744 INFO org.elasticsearch.action.bulk.BulkRequestHandler [] - Bulk request 13391 has been cancelled.
    2020.10.27 23:52:01 INFO java.lang.InterruptedException: null
    2020.10.27 23:52:01 INFO at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1040) ~[?:?]
    2020.10.27 23:52:01 INFO at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1345) ~[?:?]
    2020.10.27 23:52:01 INFO at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:232) ~[?:?]
    2020.10.27 23:52:01 INFO at org.elasticsearch.action.bulk.BulkRequestHandler.execute(BulkRequestHandler.java:78) [elasticsearch-7.5.1.jar:7.5.1]
    2020.10.27 23:52:01 INFO at org.elasticsearch.action.bulk.BulkProcessor.execute(BulkProcessor.java:455) [elasticsearch-7.5.1.jar:7.5.1]
    2020.10.27 23:52:01 INFO at org.elasticsearch.action.bulk.BulkProcessor.internalAdd(BulkProcessor.java:389) [elasticsearch-7.5.1.jar:7.5.1]
    2020.10.27 23:52:01 INFO at org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:361) [elasticsearch-7.5.1.jar:7.5.1]
    2020.10.27 23:52:01 INFO at org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:347) [elasticsearch-7.5.1.jar:7.5.1]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7BulkProcessorIndexer.add(Elasticsearch7BulkProcessorIndexer.java:72) [flink-connector-elasticsearch7_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at com.remind.graph.Job$$anon$13.process(Job.scala:312) [classes-Metals-Vx9exDKYQoitgbxsINrlCA%3d%3d/:?]
    2020.10.27 23:52:01 INFO at com.remind.graph.Job$$anon$13.process(Job.scala:286) [classes-Metals-Vx9exDKYQoitgbxsINrlCA%3d%3d/:?]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.invoke(ElasticsearchSinkBase.java:310) [flink-connector-elasticsearch-base_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:56) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:717) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:692) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:672) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:30) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at SinkConversion$136.processElement(Unknown Source) [flink-table-planner-blink_2.12-1.11.2.jar:?]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:717) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:692) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:672) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:30) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at StreamExecCalc$131.processElement(Unknown Source) [flink-table-planner-blink_2.12-1.11.2.jar:?]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:717) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:692) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:672) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:30) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.TimestampedCollector.collect(TimestampedCollector.java:53) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.table.runtime.operators.join.stream.StreamingJoinOperator.outputNullPadding(StreamingJoinOperator.java:314) [flink-table-runtime-blink_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.table.runtime.operators.join.stream.StreamingJoinOperator.processElement(StreamingJoinOperator.java:287) [flink-table-runtime-blink_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.table.runtime.operators.join.stream.StreamingJoinOperator.processElement2(StreamingJoinOperator.java:120) [flink-table-runtime-blink_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor.processRecord2(StreamTwoInputProcessor.java:142) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor.lambda$new$1(StreamTwoInputProcessor.java:105) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor$StreamTaskNetworkOutput.emitRecord(StreamTwoInputProcessor.java:364) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.processElement(StreamTaskNetworkInput.java:178) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.emitNext(StreamTaskNetworkInput.java:153) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor.processInput(StreamTwoInputProcessor.java:182) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:351) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxStep(MailboxProcessor.java:191) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:181) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:566) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:536) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721) [flink-runtime_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546) [flink-runtime_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at java.lang.Thread.run(Thread.java:834) [?:?]
    2020.10.27 23:52:01 INFO 23:52:01,745 ERROR org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase [] - Failed Elasticsearch bulk request: null
    2020.10.27 23:52:01 INFO java.lang.InterruptedException: null
    2020.10.27 23:52:01 INFO at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1040) ~[?:?]
    2020.10.27 23:52:01 INFO at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1345) ~[?:?]
    2020.10.27 23:52:01 INFO at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:232) ~[?:?]
    2020.10.27 23:52:01 INFO at org.elasticsearch.action.bulk.BulkRequestHandler.execute(BulkRequestHandler.java:78) [elasticsearch-7.5.1.jar:7.5.1]
    2020.10.27 23:52:01 INFO at org.elasticsearch.action.bulk.BulkProcessor.execute(BulkProcessor.java:455) [elasticsearch-7.5.1.jar:7.5.1]
    2020.10.27 23:52:01 INFO at org.elasticsearch.action.bulk.BulkProcessor.internalAdd(BulkProcessor.java:389) [elasticsearch-7.5.1.jar:7.5.1]
    2020.10.27 23:52:01 INFO at org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:361) [elasticsearch-7.5.1.jar:7.5.1]
    2020.10.27 23:52:01 INFO at org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:347) [elasticsearch-7.5.1.jar:7.5.1]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.connectors.elasticsearch7.Elasticsearch7BulkProcessorIndexer.add(Elasticsearch7BulkProcessorIndexer.java:72) [flink-connector-elasticsearch7_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at com.remind.graph.Job$$anon$13.process(Job.scala:312) [classes-Metals-Vx9exDKYQoitgbxsINrlCA%3d%3d/:?]
    2020.10.27 23:52:01 INFO at com.remind.graph.Job$$anon$13.process(Job.scala:286) [classes-Metals-Vx9exDKYQoitgbxsINrlCA%3d%3d/:?]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.invoke(ElasticsearchSinkBase.java:310) [flink-connector-elasticsearch-base_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at 

```

tbc

---

<div class="post-metadata">

**Author:** ![rex-remind](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/rex-remind/32/46637_2.png) [@rex-remind](https://discuss.elastic.co/u/rex-remind)\
**Post date:** [October 30, 2020, 5:55pm UTC](https://discuss.elastic.co/t/bulk-request-java-lang-interruptedexception-concurrency-issue/253850/3 "2020-10-30T17:55:17Z")

</div>

```auto
org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:56) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:717) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:692) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:672) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:30) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at SinkConversion$136.processElement(Unknown Source) [flink-table-planner-blink_2.12-1.11.2.jar:?]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:717) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:692) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:672) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:30) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at StreamExecCalc$131.processElement(Unknown Source) [flink-table-planner-blink_2.12-1.11.2.jar:?]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:717) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:692) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:672) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:30) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.api.operators.TimestampedCollector.collect(TimestampedCollector.java:53) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.table.runtime.operators.join.stream.StreamingJoinOperator.outputNullPadding(StreamingJoinOperator.java:314) [flink-table-runtime-blink_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.table.runtime.operators.join.stream.StreamingJoinOperator.processElement(StreamingJoinOperator.java:287) [flink-table-runtime-blink_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.table.runtime.operators.join.stream.StreamingJoinOperator.processElement2(StreamingJoinOperator.java:120) [flink-table-runtime-blink_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at 
org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor.processRecord2(StreamTwoInputProcessor.java:142) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor.lambda$new$1(StreamTwoInputProcessor.java:105) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor$StreamTaskNetworkOutput.emitRecord(StreamTwoInputProcessor.java:364) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.processElement(StreamTaskNetworkInput.java:178) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.emitNext(StreamTaskNetworkInput.java:153) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor.processInput(StreamTwoInputProcessor.java:182) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:351) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxStep(MailboxProcessor.java:191) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:181) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:566) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:536) [flink-streaming-java_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721) [flink-runtime_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546) [flink-runtime_2.12-1.11.2.jar:1.11.2]
    2020.10.27 23:52:01 INFO at java.lang.Thread.run(Thread.java:834) [?:?]

```

---

<div class="post-metadata">

**Author:** ![DavidTurner](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/davidturner/32/22453_2.png) [@DavidTurner](https://discuss.elastic.co/u/DavidTurner)\
**Post date:** [November 2, 2020, 8:06am UTC](https://discuss.elastic.co/t/bulk-request-java-lang-interruptedexception-concurrency-issue/253850/4 "2020-11-02T08:06:21Z")

</div>

> [@rex-remind](#):
>
> We dug in a bit more and found [https://github.com/elastic/elasticsearch/issues/36782](https://github.com/elastic/elasticsearch/issues/36782) which seems to indicate that this was failing tests at one point and then stopped happening.

That looks totally unrelated -- the issue you link was a (benign) race condition when shutting down a node, whereas you are experiencing a problem in your client.

`java.lang.InterruptedException` means that someone called `Thread#interrupt()` on the thread in question. AFAIK the only time the Elasticsearch client does so is when it is closing. Therefore either you are closing your `Client` while the bulk requests are still running, or else something else in your client is interrupting this thread.

---

<div class="post-metadata">

**Author:** ![rex-remind](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/rex-remind/32/46637_2.png) [@rex-remind](https://discuss.elastic.co/u/rex-remind)\
**Post date:** [November 4, 2020, 4:40am UTC](https://discuss.elastic.co/t/bulk-request-java-lang-interruptedexception-concurrency-issue/253850/5 "2020-11-04T04:40:51Z")

</div>

I think we traced it down to Flink killing the client. Thanks for the help.

---

<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:** [December 2, 2020, 4:40am UTC](https://discuss.elastic.co/t/bulk-request-java-lang-interruptedexception-concurrency-issue/253850/6 "2020-12-02T04:40:52Z")

</div>

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