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)