[
https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106060#comment-17106060
]
jackylau commented on FLINK-16713:
----------------------------------
Hi [~jackray], [~jark] where to find your design docs, we also want to support
es source.
1) we just support es batch source currently
2) after flink 1.11, flink support change log(DynamicSource), then we will
support es translog to suuport update
> Support source mode of elasticsearch connector
> ----------------------------------------------
>
> Key: FLINK-16713
> URL: https://issues.apache.org/jira/browse/FLINK-16713
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / ElasticSearch
> Affects Versions: 1.10.0
> Reporter: jackray wang
> Priority: Major
>
> [https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#elasticsearch-connector]
> For append-only queries, the connector can also operate in [append
> mode|https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#update-modes]
> for exchanging only INSERT messages with the external system. If no key is
> defined by the query, a key is automatically generated by Elasticsearch.
> I want to know ,why the connector of flink with ES just support sink butÂ
> doesn't support source .Which version could add this feature to ?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
