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

Posted to issues@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/13 06:28:06 UTC

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

     [ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Yun Gao updated FLINK-21022:
----------------------------
    Fix Version/s: 1.16.0

> flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking
> -------------------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-21022
>                 URL: https://issues.apache.org/jira/browse/FLINK-21022
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / ElasticSearch
>            Reporter: Zheng WEI
>            Priority: Minor
>              Labels: auto-deprioritized-major, pull-request-available
>             Fix For: 1.15.0, 1.11.7, 1.16.0
>
>
> flink-connector-es add onSuccess handler after successful bulk process, in order to sync success data to other third party system for data consistency checking. Default the implementation of onSuccess function is empty logic, user can set its own onSuccess handler when needed.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)