[
https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070828#comment-17070828
]
jackray wang edited comment on FLINK-16713 at 3/30/20, 9:25 AM:
----------------------------------------------------------------
[~jark] I am so Sorry ,last week，for me is too busy to log in this website. I
know about the lock mechanism of ES not too much，but Kibana can show the data
in the form of time intervals. Maybe we can learn from it.
The scenario ,our company needs is just to get data from ES, not necessarily in
the form of flow. Let me think again about how to get the data from ES by
stream.
was (Author: jackray):
[~jark] I so Sorry ,last week，for me is too busy to log in this website. I
know about the lock mechanism of ES not too much，but Kibana can show the data
in the form of time intervals. Maybe we can learn from it.
The scenario ,our company needs is just to get data from ES, not necessarily in
the form of flow. Let me think again about how to get the data from ES by
stream.
> 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)
