Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-18535

Elasticsearch connector hangs for threads deadlocked

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Important

    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.

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            DeFOX DeFOX

            Dates

              Created:
              Updated:

              Slack

                Issue deployment