[ https://issues.apache.org/jira/browse/FLINK-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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)