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

Posted to dev@flink.apache.org by "tartarus (Jira)" <ji...@apache.org> on 2021/07/29 03:27:00 UTC

[jira] [Created] (FLINK-23531) Allow skip everytime change log for row-time deduplicate mini-batch

tartarus created FLINK-23531:
--------------------------------

             Summary: Allow skip everytime change log for row-time deduplicate mini-batch
                 Key: FLINK-23531
                 URL: https://issues.apache.org/jira/browse/FLINK-23531
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Runtime
            Reporter: tartarus


current we keep everytime change log for row-time deduplicate mini-batch,

we need buffer all record on heap.

In some cases, users do not need all change logs;
In this way, the memory pressure and the calculation pressure of downstream operators can be reduced



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