[FLINK-18535] Elasticsearch connector hangs for threads deadlocked

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.10.0
• Component/s: Connectors / ElasticSearch
• Labels: Connector ElasticSearch auto-deprioritized-major auto-deprioritized-minor
• Flags: Important
• Assignee: Unassigned
• Reporter: DeFOX
• Created: 09/Jul/20 06:23
• Updated: 30/Nov/21 20:37

Description

When using the connector created by org.apache.flink.streaming.connectors.elasticsearch7.ElasticsearchSink.Builder to sink data to ES(es7.7.1 and es6.8.5), flink job will finally hang for threads deadlocked after a while.

And connector created by org.apache.flink.streaming.connectors.elasticsearch6.ElasticsearchSink.Builder will not result in this deadlocked situation.

This deadlocked issue may come from this pr：https://github.com/elastic/elasticsearch/pull/41451

So upgrade version of the dependencies of ES may fix this bug.

Issue Links

• is fixed by: FLINK-15558 Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector