You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Cheng Shi (Jira)" <ji...@apache.org> on 2020/05/07 02:20:00 UTC

[jira] [Created] (FLINK-17550) set a retract switch

Cheng Shi created FLINK-17550:
---------------------------------

             Summary: set a retract switch
                 Key: FLINK-17550
                 URL: https://issues.apache.org/jira/browse/FLINK-17550
             Project: Flink
          Issue Type: New Feature
            Reporter: Cheng Shi


During the execution of flink, especially the sql API, many operations in DataStream are not available. In many cases, we don't care about the DELETE record when retracting. Is it possible to set a switch so that the DELETE record when retracting is not processed? In other words, the downstream only receives a value after UPDATE, and does not need to receive the value before UPDATE. In some programming modes, processing DELETE records actually makes the logic more complicated.



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