[ https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17389248#comment-17389248 ]
tartarus commented on FLINK-23531: ---------------------------------- [~jark] please assign to me, thanks > 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 > Priority: Major > > 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)