[jira] [Commented] (FLINK-8579) Support deletion flag for DataStream to Table upsert conversion.
[ https://issues.apache.org/jira/browse/FLINK-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356914#comment-16356914 ] Hequn Cheng commented on FLINK-8579: OK, I will close this issue. I intend to make each pr functionally-independent and small. > Support deletion flag for DataStream to Table upsert conversion. > > > Key: FLINK-8579 > URL: https://issues.apache.org/jira/browse/FLINK-8579 > Project: Flink > Issue Type: Sub-task > Components: Table API SQL >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > > Add deletion flag support, so the source can ingests delete messages. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (FLINK-8579) Support deletion flag for DataStream to Table upsert conversion.
[ https://issues.apache.org/jira/browse/FLINK-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356720#comment-16356720 ] Fabian Hueske commented on FLINK-8579: -- I think this should be directly addressed by FLINK-8577 and FLINK-8578 because it is orthogonal to the choice of processing time or rowtime. Hence, I suggest to close this issue. > Support deletion flag for DataStream to Table upsert conversion. > > > Key: FLINK-8579 > URL: https://issues.apache.org/jira/browse/FLINK-8579 > Project: Flink > Issue Type: Sub-task > Components: Table API SQL >Reporter: Hequn Cheng >Assignee: Hequn Cheng >Priority: Major > > Add deletion flag support, so the source can ingests delete messages. -- This message was sent by Atlassian JIRA (v7.6.3#76005)