You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Enrico Canzonieri (Jira)" <ji...@apache.org> on 2019/09/19 22:07:00 UTC
[jira] [Commented] (FLINK-8545) Implement upsert stream table
source
[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933807#comment-16933807 ]
Enrico Canzonieri commented on FLINK-8545:
------------------------------------------
Is this ticket still being considered? Being able to directly ingest retract DataStream in the Table API seems a valuable feature. In our deployment we have many use cases where we stream CDC from MySQL or Cassandra to Kafka. Supporting retract DataStream in the Table API would allow us to use Flink SQL to manipulate these streams in realtime.
> Implement upsert stream table source
> -------------------------------------
>
> Key: FLINK-8545
> URL: https://issues.apache.org/jira/browse/FLINK-8545
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
> Reporter: Hequn Cheng
> Assignee: Hequn Cheng
> Priority: Major
>
> As more and more users are eager for ingesting data with upsert mode in flink sql/table-api, it is valuable to enable table source with upsert mode. I will provide a design doc later and we can have more discussions. Any suggestions are warmly welcomed !
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)