[
https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106353#comment-17106353
]
Jark Wu commented on FLINK-16713:
---------------------------------
Hi [~jackylau], I think we can start from bounded source. Support elasticsearch
as unbounded stream source is an interesting feature, why not support it in
Flink repository? We already have elasticsearch connector in Flink repository.
> 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)
