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)