[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Attachment: (was: Screenshot 2023-07-31 at 10.37.11 AM-1.png) > 'UNION ALL' with a

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Attachment: (was: Screenshot 2023-07-31 at 10.37.11 AM-3.png) > 'UNION ALL' with a

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Attachment: (was: Screenshot 2023-07-31 at 10.37.11 AM-2.png) > 'UNION ALL' with a

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Description: I am having trouble understanding why adding a 'UNION ALL' with a 'GROUP BY'

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Attachment: (was: Screenshot 2023-07-31 at 10.37.11 AM.png) > 'UNION ALL' with a 'GROUP

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Attachment: withoutHeader.png > 'UNION ALL' with a 'GROUP BY' condition in Flink is causing

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Attachment: Screenshot 2023-07-31 at 10.37.11 AM-3.png > 'UNION ALL' with a 'GROUP BY'

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Attachment: Screenshot 2023-07-31 at 10.37.11 AM-2.png > 'UNION ALL' with a 'GROUP BY'

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Description: I am having trouble understanding why adding a 'UNION ALL' with a 'GROUP BY'

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Attachment: Screenshot 2023-07-31 at 10.37.11 AM-1.png > 'UNION ALL' with a 'GROUP BY'

[jira] [Comment Edited] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766730#comment-17766730 ] Neha Aggarwal edited comment on FLINK-32718 at 9/19/23 10:10 AM: -

[jira] [Commented] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766730#comment-17766730 ] Neha Aggarwal commented on FLINK-32718: --- [~qingyue]  I understand that the checkpoint size will be

[jira] [Commented] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766622#comment-17766622 ] Neha Aggarwal commented on FLINK-32718: --- Hello Jane Chan, I am attaching the Physical Plan. Let

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Priority: Major (was: Blocker) > 'UNION ALL' with a 'GROUP BY' condition in Flink is

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Environment: Apache Flink 1.16.1 (was: Apache Flink Kubernetes Operator 1.3.1 Kubernetes

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Affects Version/s: 1.16.1 (was: kubernetes-operator-1.3.1) >

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Component/s: Table SQL / API Table SQL / Planner (was:

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Labels: (was: pull-request-available) > 'UNION ALL' with a 'GROUP BY' condition in Flink

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Description: I am having trouble understanding why adding a 'UNION ALL' with a 'GROUP BY'

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Description: I am having trouble understanding why adding a 'UNION ALL' with a 'GROUP BY'

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Description: I am having trouble understanding why adding a 'UNION ALL' with a 'GROUP BY'

[jira] [Updated] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-32718: -- Attachment: Screenshot 2023-07-31 at 10.37.11 AM.png Screenshot 2023-07-31 at

[jira] [Created] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

Neha Aggarwal created FLINK-32718: - Summary: 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded Key: FLINK-32718 URL: https://issues.apache.org/jira/browse/FLINK-32718

[jira] [Comment Edited] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698358#comment-17698358 ] Neha Aggarwal edited comment on FLINK-30238 at 3/9/23 12:33 PM:

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698358#comment-17698358 ] Neha Aggarwal commented on FLINK-30238: --- Attaching the screenshot of one Kafka source and Delta

[jira] [Updated] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-30238: -- Attachment: image (8).png > Unified Sink committer does not clean up state on final savepoint

[jira] [Updated] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Aggarwal updated FLINK-30238: -- Attachment: Screenshot 2023-03-09 at 1.47.11 PM.png > Unified Sink committer does not clean

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696852#comment-17696852 ] Neha Aggarwal commented on FLINK-30238: --- While migrating from Flink 1.13 to Flink 1.16, I found

[jira] [Comment Edited] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696060#comment-17696060 ] Neha Aggarwal edited comment on FLINK-30238 at 3/3/23 7:36 AM: --- This issue

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696060#comment-17696060 ] Neha Aggarwal commented on FLINK-30238: --- This issue is not limited to stop-with-savepoint, It is