You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "sanqingleo (Jira)" <ji...@apache.org> on 2024/08/23 07:59:00 UTC

[jira] [Created] (FLINK-36143) Sink ES occurred "version conflict"

sanqingleo created FLINK-36143:
----------------------------------

             Summary: Sink ES occurred "version conflict"
                 Key: FLINK-36143
                 URL: https://issues.apache.org/jira/browse/FLINK-36143
             Project: Flink
          Issue Type: New Feature
          Components: Connectors / ElasticSearch
    Affects Versions: elasticsearch-3.0.0
         Environment: Flink 1.18
ES 7.4x
connector 3.0.0
            Reporter: sanqingleo


When I used ES connector Write update datas, it occurred "version conflict", like this " org.elasticsearch.index.engine.VersionConflictEngineException: [project][1140860]: version conflict, current version [5] is different than the one provided [4]
"

When we set the conf  failure-handler = ignore, It lead to lost data, and if set the conf failure-handler = fail, job will restore. this cost is too heavy. maybe  second try it will success.

so  I set this conf param, this will make job failed cost smaller.  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)