[
https://issues.apache.org/jira/browse/FLINK-18432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
rinkako closed FLINK-18432.
---
Fix Version/s: 1.12.0
Resolution: Duplicate
> add open and close methods for
[
https://issues.apache.org/jira/browse/FLINK-18432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17144821#comment-17144821
]
rinkako commented on FLINK-18432:
-
Thanks [~jark] , this is actually what I mean, and it already fixed
rinkako created FLINK-18432:
---
Summary: add open and close methods for ElasticsearchSinkFunction
interface
Key: FLINK-18432
URL: https://issues.apache.org/jira/browse/FLINK-18432
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
rinkako updated FLINK-18359:
Affects Version/s: (was: 1.10.0)
> Improve error-log strategy for Elasticsearch sink for large data
[
https://issues.apache.org/jira/browse/FLINK-18359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
rinkako updated FLINK-18359:
Labels: usability (was: )
> Improve error-log strategy for Elasticsearch sink for large data documentId
[
https://issues.apache.org/jira/browse/FLINK-18359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
rinkako updated FLINK-18359:
Affects Version/s: 1.10.0
> Improve error-log strategy for Elasticsearch sink for large data documentId
[
https://issues.apache.org/jira/browse/FLINK-18359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
rinkako updated FLINK-18359:
Component/s: Connectors / ElasticSearch
> Improve error-log strategy for Elasticsearch sink for large
[
https://issues.apache.org/jira/browse/FLINK-18359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
rinkako updated FLINK-18359:
Description:
The story is: when a flink job for ingesting large number of records from data
sources,
rinkako created FLINK-18359:
---
Summary: Improve error-log strategy for Elasticsearch sink for
large data documentId conflict when using create mode for `insert ignore`
semantics
Key: FLINK-18359
URL: