[ 
https://issues.apache.org/jira/browse/FLINK-18028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127861#comment-17127861
 ] 

Shengkai Fang commented on FLINK-18028:
---------------------------------------

Currently we have cases: KafkaJoinJdbc2AppendJdbc and KafkaJoinJdbc2UpsertJdbc.

The goal of KafkaJoinJdbc2AppendJdbc is to test whether we can use Mysql as 
lookup table source and whether we can write to Mysql using streaming append 
mode.

The goal of KafkaJoinJdbc2UpsertJdbc is to test whether we can use Mysql as 
lookup table source and whether we can write to Mysql using streaming upsert 
mode.

Every case has two versions: the old connector property keys and new connector 
property keys. 

> E2E tests manually for MySQL JDBC
> ---------------------------------
>
>                 Key: FLINK-18028
>                 URL: https://issues.apache.org/jira/browse/FLINK-18028
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / Kafka, Tests
>    Affects Versions: 1.11.0
>            Reporter: Danny Chen
>            Assignee: Shengkai Fang
>            Priority: Blocker
>             Fix For: 1.11.0
>
>
> - test Kafka lookup join MySQL
> - test Kafka 2 MySQL with insert-only query
> - test Kafka 2 MySQL with upsert query



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to