[
https://issues.apache.org/jira/browse/FLINK-36143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36143:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Priority: Major
> Labels: pull-request-available
>
> 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)