[
https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065317#comment-17065317
]
jackray wang edited comment on FLINK-16713 at 3/24/20, 5:04 AM:
----------------------------------------------------------------
I will prepare a design doc for you and describe my ideas in as much detail as
possible.
What we do is for the operation and maintenance colleagues, who often look at
the data from different latitudes, and need constant debugging to determine the
final script. After processing, our data is put in ES, so this feature is
important for us.
If we discovery some error or warning in Es ,we will send them to kafka or
other components to inform relevant personnel to deal with the problem ,etc..
[~jark]
was (Author: jackray):
I will prepare a design doc for you and describe my ideas in as much detail as
possible.
What we do is for the operation and maintenance colleagues, who often look at
the data from different latitudes, and need constant debugging to determine the
final script. After processing, our data is put in ES, so this feature is
important for us.
If we discovery some error or warning in Es ,we will sent them to kafka or
other components to inform relevant personnel to deal with the problem ,etc..
> 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)
