[jira] [Created] (FLINK-33138) Prometheus Connector Sink - DataStream API implementation

2023-09-23 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33138: -- Summary: Prometheus Connector Sink - DataStream API implementation Key: FLINK-33138 URL: https://issues.apache.org/jira/browse/FLINK-33138 Project: Flink

[jira] [Created] (FLINK-33137) FLIP-312: Prometheus Sink Connector

2023-09-23 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33137: -- Summary: FLIP-312: Prometheus Sink Connector Key: FLINK-33137 URL: https://issues.apache.org/jira/browse/FLINK-33137 Project: Flink Issue Type: New Featu

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

2023-09-23 Thread Neha Aggarwal (Jira)
[ 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 'GROUP

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

2023-09-23 Thread Neha Aggarwal (Jira)
[ 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 'GROUP

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

2023-09-23 Thread Neha Aggarwal (Jira)
[ 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 'GROUP

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

2023-09-23 Thread Neha Aggarwal (Jira)
[ 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' con

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

2023-09-23 Thread Neha Aggarwal (Jira)
[ 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 B

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

2023-09-23 Thread Neha Aggarwal (Jira)
[ 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 t

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

2023-09-23 Thread Neha Aggarwal (Jira)
[ 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' condit

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

2023-09-23 Thread Neha Aggarwal (Jira)
[ 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' condit

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

2023-09-23 Thread Neha Aggarwal (Jira)
[ 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' con

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

2023-09-23 Thread Neha Aggarwal (Jira)
[ 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' condit

[jira] [Updated] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

2023-09-23 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26974: --- Labels: auto-deprioritized-major stale-assigned test-stability (was: auto-deprioritized-maj

[jira] [Updated] (FLINK-32605) JoinITCase.testFullOuterJoinWithMultipleKeys fails with TimeoutException: Futures timed out after [20 seconds]

2023-09-23 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32605: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability) Pri

[jira] [Updated] (FLINK-28879) New File Sink s3 end-to-end test failed with Output hash mismatch

2023-09-23 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28879: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-31860) FlinkDeployments never finalize when namespace is deleted

2023-09-23 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31860: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-33135) Flink Pulsar Connector Attempts Partitioned Routing on Unpartitioned Topic

2023-09-23 Thread Jason Kania (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Kania updated FLINK-33135: Description: For a non-partitioned topic, the Flink Pulsar connector creates a TopicRouter, ensur

[jira] [Updated] (FLINK-33135) Flink Pulsar Connector Attempts Partitioned Routing on Unpartitioned Topic

2023-09-23 Thread Jason Kania (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Kania updated FLINK-33135: Description: For a non-partitioned topic, the Flink Pulsar connector creates a TopicRouter, ensur

[jira] [Updated] (FLINK-33135) Flink Pulsar Connector Attempts Partitioned Routing on Unpartitioned Topic

2023-09-23 Thread Jason Kania (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Kania updated FLINK-33135: Description: For a non-partitioned topic, the Flink Pulsar connector creates a TopicRouter, ensur

[jira] [Updated] (FLINK-33135) Flink Pulsar Connector Attempts Partitioned Routing on Unpartitioned Topic

2023-09-23 Thread Jason Kania (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Kania updated FLINK-33135: Description: For a non-partitioned topic, the Flink Pulsar connector creates a TopicRouter, ensur

[jira] [Created] (FLINK-33136) Flink Pulsar Connector RoundRobinTopicRouter Generates Invalid Error Message

2023-09-23 Thread Jason Kania (Jira)
Jason Kania created FLINK-33136: --- Summary: Flink Pulsar Connector RoundRobinTopicRouter Generates Invalid Error Message Key: FLINK-33136 URL: https://issues.apache.org/jira/browse/FLINK-33136 Project: F

[jira] [Created] (FLINK-33135) Flink Pulsar Connector Attempts Partitioned Routing on Unpartitioned Topic

2023-09-23 Thread Jason Kania (Jira)
Jason Kania created FLINK-33135: --- Summary: Flink Pulsar Connector Attempts Partitioned Routing on Unpartitioned Topic Key: FLINK-33135 URL: https://issues.apache.org/jira/browse/FLINK-33135 Project: Fli

[jira] [Updated] (FLINK-31854) FLIP-307: Flink Connector Redshift

2023-09-23 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb updated FLINK-31854: --- Labels: (was: aws) > FLIP-307: Flink Connector Redshift > --- > >

[jira] [Updated] (FLINK-31854) FLIP-307: Flink Connector Redshift

2023-09-23 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb updated FLINK-31854: --- Labels: aws (was: ) > FLIP-307: Flink Connector Redshift > --- > >

[jira] [Created] (FLINK-33134) Flink Connector redshift E2E test

2023-09-23 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-33134: -- Summary: Flink Connector redshift E2E test Key: FLINK-33134 URL: https://issues.apache.org/jira/browse/FLINK-33134 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33133) Flink Document Update

2023-09-23 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-33133: -- Summary: Flink Document Update Key: FLINK-33133 URL: https://issues.apache.org/jira/browse/FLINK-33133 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-33132) Flink Connector Redshift Sink Implementation

2023-09-23 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-33132: -- Summary: Flink Connector Redshift Sink Implementation Key: FLINK-33132 URL: https://issues.apache.org/jira/browse/FLINK-33132 Project: Flink Issue Type: Sub-tas

[jira] [Updated] (FLINK-31854) FLIP-307: Flink Connector Redshift

2023-09-23 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb updated FLINK-31854: --- Summary: FLIP-307: Flink Connector Redshift (was: Flink connector redshift ) > FLIP-307: Flink Co

[GitHub] [flink] jayadeep-jayaraman commented on pull request #22281: [FLINK-31631][FileSystems] Upgrade GCS connector to 2.2.11.

2023-09-23 Thread via GitHub
jayadeep-jayaraman commented on PR #22281: URL: https://github.com/apache/flink/pull/22281#issuecomment-1732361470 Hi @cnauroth - There are multiple code paths and API's in Flink which uses different google libraries and we should make them consistent. For instance - Writes that u

[jira] [Created] (FLINK-33131) Grafana dashboard for flink k8 operator metrics

2023-09-23 Thread Gaurav Miglani (Jira)
Gaurav Miglani created FLINK-33131: -- Summary: Grafana dashboard for flink k8 operator metrics Key: FLINK-33131 URL: https://issues.apache.org/jira/browse/FLINK-33131 Project: Flink Issue Typ

[GitHub] [flink] cnauroth commented on pull request #22281: [FLINK-31631][FileSystems] Upgrade GCS connector to 2.2.11.

2023-09-23 Thread via GitHub
cnauroth commented on PR #22281: URL: https://github.com/apache/flink/pull/22281#issuecomment-1732359065 @yigress , thank you for reporting this. The stack trace appears to be in the checkpointing code path, which uses the GCS client directly (not the Hadoop `FileSystem`). Looking bac

[jira] [Updated] (FLINK-33098) Support kubernetes autoscaler using generic interface

2023-09-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33098: Description: # Moving all classes aren't related to kubernetes to flink-autoscaler module # Support kube

[jira] [Updated] (FLINK-33098) Support kubernetes autoscaler using generic interface

2023-09-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33098: Description: # Moving all classes aren't related to kubernetes to flink-autoscaler module # Support kuber

[GitHub] [flink-connector-aws] hlteoh37 commented on pull request #94: [FLINK-33073][Connectors/AWS] Implement end-to-end tests for KinesisS…

2023-09-23 Thread via GitHub
hlteoh37 commented on PR #94: URL: https://github.com/apache/flink-connector-aws/pull/94#issuecomment-1732336801 Verified that running AWS end-to-end tests locally all pass ``` FLINK_AWS_USER= FLINK_AWS_PASSWORK= mvn clean verify -Prun-aws-end-to-end-tests -DdistDir=~/workplace/

[jira] [Commented] (FLINK-27429) Implement Vertica JDBC Dialect

2023-09-23 Thread Jasmin Redzepovic (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768257#comment-17768257 ] Jasmin Redzepovic commented on FLINK-27429: --- Hi [~snuyanzin] , could you pleas

[jira] [Commented] (FLINK-30831) Improving e2e test output in case errors/exceptions are found

2023-09-23 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768256#comment-17768256 ] Flaviu Cicio commented on FLINK-30831: -- [~mapohl] Can I take this ticket as my firs

[jira] [Comment Edited] (FLINK-30831) Improving e2e test output in case errors/exceptions are found

2023-09-23 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768256#comment-17768256 ] Flaviu Cicio edited comment on FLINK-30831 at 9/23/23 9:55 AM: ---

[jira] [Updated] (FLINK-27429) Implement Vertica JDBC Dialect

2023-09-23 Thread Jasmin Redzepovic (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jasmin Redzepovic updated FLINK-27429: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > Impleme