[
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)
