[jira] [Commented] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882911#comment-17882911 ] Lorenzo Affetti commented on FLINK-31762: - Hello [~arvid]  Sorry for the late r

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856514#comment-17856514 ] Lorenzo Affetti edited comment on FLINK-31762 at 6/20/24 2:48 PM:

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856514#comment-17856514 ] Lorenzo Affetti edited comment on FLINK-31762 at 6/20/24 2:48 PM:

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856514#comment-17856514 ] Lorenzo Affetti edited comment on FLINK-31762 at 6/20/24 2:44 PM:

[jira] [Commented] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856514#comment-17856514 ] Lorenzo Affetti commented on FLINK-31762: - Thank you [~jingge] !   This would

[jira] [Commented] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855964#comment-17855964 ] Lorenzo Affetti commented on FLINK-31762: - Hello! Is anybody working on this? O

[jira] [Updated] (FLINK-35591) Azure Pipelines not running for master since c9def981

[ https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Affetti updated FLINK-35591: Attachment: image-2024-06-13-12-31-18-076.png > Azure Pipelines not running for master sin

[jira] [Commented] (FLINK-35591) Azure Pipelines not running for master since c9def981

[ https://issues.apache.org/jira/browse/FLINK-35591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854705#comment-17854705 ] Lorenzo Affetti commented on FLINK-35591: - Back to normality !image-2024-06-13-

[jira] [Commented] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846975#comment-17846975 ] Lorenzo Affetti commented on FLINK-20628: - Sure thing, thank you [~chalixar] !

[jira] [Commented] (FLINK-20392) Migrating bash e2e tests to Java/Docker

[ https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846873#comment-17846873 ] Lorenzo Affetti commented on FLINK-20392: - [~mapohl] [~m.orazow]    thanks for

[jira] [Commented] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink

[ https://issues.apache.org/jira/browse/FLINK-26821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846558#comment-17846558 ] Lorenzo Affetti commented on FLINK-26821: - [~mzuehlke] are you working on this?

[jira] [Commented] (FLINK-20625) Refactor Google Cloud PubSub Source in accordance with FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-20625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846554#comment-17846554 ] Lorenzo Affetti commented on FLINK-20625: - [~clmccart] still actively working on

[jira] [Commented] (FLINK-24299) Make Google PubSub available as Source and Sink for Table API

[ https://issues.apache.org/jira/browse/FLINK-24299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846551#comment-17846551 ] Lorenzo Affetti commented on FLINK-24299: - I see there is no pull request for th

[jira] [Commented] (FLINK-20392) Migrating bash e2e tests to Java/Docker

[ https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846535#comment-17846535 ] Lorenzo Affetti commented on FLINK-20392: - [~m.orazow] and I found ourselves wor

[jira] [Commented] (FLINK-16528) Support Limit push down for Kafka streaming sources

[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845894#comment-17845894 ] Lorenzo Affetti commented on FLINK-16528: - [~jark] is this issue still valuable

[jira] [Commented] (FLINK-34999) PR CI stopped operating

[ https://issues.apache.org/jira/browse/FLINK-34999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833887#comment-17833887 ] Lorenzo Affetti commented on FLINK-34999: - Flink CI Bot had invalid credentials.

[jira] [Commented] (FLINK-34999) PR CI stopped operating

[ https://issues.apache.org/jira/browse/FLINK-34999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833563#comment-17833563 ] Lorenzo Affetti commented on FLINK-34999: - Hello [~mapohl] , I think Jing is not

[jira] [Commented] (FLINK-34581) streaming code throws java.lang.reflect.InaccessibleObjectException

[ https://issues.apache.org/jira/browse/FLINK-34581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823904#comment-17823904 ] Lorenzo Affetti commented on FLINK-34581: - Hello, could you please check if you

[jira] [Commented] (FLINK-20392) Migrating bash e2e tests to Java/Docker

[ https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823242#comment-17823242 ] Lorenzo Affetti commented on FLINK-20392: - {quote}I'm not able to follow what yo

[jira] [Commented] (FLINK-20392) Migrating bash e2e tests to Java/Docker

[ https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823188#comment-17823188 ] Lorenzo Affetti commented on FLINK-20392: - [~mapohl] [~jark]  In order to bette

[jira] [Created] (FLINK-34562) Port Debezium Avro Confluent changes (FLINK-34509) to Chinese

Lorenzo Affetti created FLINK-34562: --- Summary: Port Debezium Avro Confluent changes (FLINK-34509) to Chinese Key: FLINK-34562 URL: https://issues.apache.org/jira/browse/FLINK-34562 Project: Flink

[jira] [Commented] (FLINK-20392) Migrating bash e2e tests to Java/Docker

[ https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822606#comment-17822606 ] Lorenzo Affetti commented on FLINK-20392: - Hello, I would like to take https://i

[jira] [Commented] (FLINK-20399) Migrate test_sql_client.sh

[ https://issues.apache.org/jira/browse/FLINK-20399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822599#comment-17822599 ] Lorenzo Affetti commented on FLINK-20399: - would like to work on this, can someb

[jira] [Created] (FLINK-34509) Docs: Fix Debezium JSON/AVRO opts in examples

Lorenzo Affetti created FLINK-34509: --- Summary: Docs: Fix Debezium JSON/AVRO opts in examples Key: FLINK-34509 URL: https://issues.apache.org/jira/browse/FLINK-34509 Project: Flink Issue Ty

[jira] [Comment Edited] (FLINK-34202) python tests take suspiciously long in some of the cases

[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819273#comment-17819273 ] Lorenzo Affetti edited comment on FLINK-34202 at 2/21/24 2:18 PM:

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819273#comment-17819273 ] Lorenzo Affetti commented on FLINK-34202: - [~mapohl] thanks for pointing that ou

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819180#comment-17819180 ] Lorenzo Affetti commented on FLINK-34202: - Update, CI001 looks just a bit overco

[jira] [Updated] (FLINK-34202) python tests take suspiciously long in some of the cases

[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Affetti updated FLINK-34202: Attachment: Screenshot 2024-02-21 at 09.45.18.png > python tests take suspiciously long in

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818698#comment-17818698 ] Lorenzo Affetti commented on FLINK-34202: - Sure thing (y) > python tests take s

[jira] [Commented] (FLINK-34459) Results column names should match SELECT clause expression names

[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818385#comment-17818385 ] Lorenzo Affetti commented on FLINK-34459: - [~martijnvisser] well, if the name is