[
https://issues.apache.org/jira/browse/FLINK-37200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17921621#comment-17921621
]
qinghuan wang commented on FLINK-37200:
---------------------------------------
https://github.com/apache/flink-cdc/pull/3898
> Add e2e test for ElasticSearch Sink.
> ------------------------------------
>
> Key: FLINK-37200
> URL: https://issues.apache.org/jira/browse/FLINK-37200
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Affects Versions: cdc-3.3.0
> Reporter: Yanquan Lv
> Assignee: Yanquan Lv
> Priority: Major
> Fix For: cdc-3.4.0
>
>
> Add e2e test for ElasticSearch Sink.
> For example:
> ```
> source:
> type: mysql
> name: MySQL Source
> hostname: 127.0.0.1
> port: 3306
> username: admin
> password: pass
> tables: adb.\.*, bdb.user_table_[0-9]+, [app|web].order_\.*
> server-id: 5401-5404
> sink:
> type: elasticsearch
> name: Elasticsearch Sink
> hosts: http://127.0.0.1:9092,http://127.0.0.1:9093
> route:
> - source-table: adb.\.*
> sink-table: default_index
> description: sync adb.\.* table to default_index
> pipeline:
> name: MySQL to Elasticsearch Pipeline
> parallelism: 2
> ```
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
