[jira] [Updated] (FLINK-37289) Resolve JVM bytecode size limit exceeded in method due to excessive field initializations in SQL job

2025-02-08 Thread Xinglong Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinglong Wang updated FLINK-37289: -- Description: h3. Problem Description The SQL job encounters issues due to having too many fie

[jira] [Created] (FLINK-37289) Resolve JVM bytecode size limit exceeded in method due to excessive field initializations in SQL job

2025-02-08 Thread Xinglong Wang (Jira)
Xinglong Wang created FLINK-37289: - Summary: Resolve JVM bytecode size limit exceeded in method due to excessive field initializations in SQL job Key: FLINK-37289 URL: https://issues.apache.org/jira/browse/FLINK-

Re: [PR] [FLINK-37288] Add flink-connector-jdbc-spnner [flink-connector-jdbc]

2025-02-08 Thread via GitHub
boring-cyborg[bot] commented on PR #156: URL: https://github.com/apache/flink-connector-jdbc/pull/156#issuecomment-2646096018 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc]

2025-02-08 Thread via GitHub
laughingman7743 commented on code in PR #156: URL: https://github.com/apache/flink-connector-jdbc/pull/156#discussion_r1948022033 ## flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/testutils/tables/TableBase.java: ## @@ -120,7 +122,7 @@ public int[] getT

[jira] [Updated] (FLINK-37288) Add Google Cloud Spanner dialect and catalog

2025-02-08 Thread Tomoyuki NAKAMURA (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tomoyuki NAKAMURA updated FLINK-37288: -- External issue ID: (was: https://github.com/apache/flink-connector-jdbc/pull/156) >

Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc]

2025-02-08 Thread via GitHub
laughingman7743 commented on code in PR #156: URL: https://github.com/apache/flink-connector-jdbc/pull/156#discussion_r1948021540 ## flink-connector-jdbc-spanner/src/test/java/org/apache/flink/connector/jdbc/spanner/SpannerTestBase.java: ## @@ -16,27 +16,19 @@ * limitations u

Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc]

2025-02-08 Thread via GitHub
laughingman7743 commented on code in PR #156: URL: https://github.com/apache/flink-connector-jdbc/pull/156#discussion_r1948021458 ## flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/AbstractJdbcCatalog.java: ## @@ -576,16 +569,6 @@ p

Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc]

2025-02-08 Thread via GitHub
laughingman7743 commented on code in PR #156: URL: https://github.com/apache/flink-connector-jdbc/pull/156#discussion_r1948021405 ## flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/database/catalog/AbstractJdbcCatalog.java: ## @@ -125,17 +125,10 @@

[jira] [Updated] (FLINK-37288) Add Google Cloud Spanner dialect and catalog

2025-02-08 Thread Tomoyuki NAKAMURA (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tomoyuki NAKAMURA updated FLINK-37288: -- External issue ID: https://github.com/apache/flink-connector-jdbc/pull/156 > Add Googl

[jira] [Commented] (FLINK-37288) Add Google Cloud Spanner dialect and catalog

2025-02-08 Thread Tomoyuki NAKAMURA (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925344#comment-17925344 ] Tomoyuki NAKAMURA commented on FLINK-37288: --- I created a PR on GitHub. https:

[jira] [Updated] (FLINK-37288) Add Google Cloud Spanner dialect and catalog

2025-02-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37288: --- Labels: pull-request-available (was: ) > Add Google Cloud Spanner dialect and catalog > ---

[jira] [Created] (FLINK-37288) Add Google Cloud Spanner dialect and catalog

2025-02-08 Thread Tomoyuki NAKAMURA (Jira)
Tomoyuki NAKAMURA created FLINK-37288: - Summary: Add Google Cloud Spanner dialect and catalog Key: FLINK-37288 URL: https://issues.apache.org/jira/browse/FLINK-37288 Project: Flink Issue

Re: [PR] [FLINK-36604][datastream] StreamingJobGraphGenerator::setOperatorConfig checks input serializer length [flink]

2025-02-08 Thread via GitHub
liuml07 commented on code in PR #25576: URL: https://github.com/apache/flink/pull/25576#discussion_r1948007803 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java: ## @@ -1191,6 +1191,12 @@ public static void setOperatorConfig(

Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink]

2025-02-08 Thread via GitHub
sujay-jain commented on code in PR #24205: URL: https://github.com/apache/flink/pull/24205#discussion_r1947967477 ## flink-core/src/main/java/org/apache/flink/api/java/ClosureCleaner.java: ## @@ -66,14 +67,20 @@ public class ClosureCleaner { */ public static void clea

Re: [PR] [FLINK-36604][datastream] StreamingJobGraphGenerator::setOperatorConfig checks input serializer length [flink]

2025-02-08 Thread via GitHub
sujay-jain commented on code in PR #25576: URL: https://github.com/apache/flink/pull/25576#discussion_r1947934751 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java: ## @@ -1191,6 +1191,12 @@ public static void setOperatorConfig(

[jira] [Updated] (FLINK-37281) Refactor KafkaSinkITCase

2025-02-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37281: --- Labels: pull-request-available (was: ) > Refactor KafkaSinkITCase > ---

[jira] [Commented] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint

2025-02-08 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925300#comment-17925300 ] Arvid Heise commented on FLINK-34554: - Too much stuff came IRL to be able to push it

[jira] [Assigned] (FLINK-24252) HybridSource should return TypeInformation

2025-02-08 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24252: --- Assignee: (was: Arvid Heise) > HybridSource should return TypeInformation > ---

[jira] [Commented] (FLINK-37108) Source/Sink test suites test invalid recovery

2025-02-08 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925298#comment-17925298 ] Arvid Heise commented on FLINK-37108: - Merged into master as 1adcf1e, into 1.20 as e

[jira] [Resolved] (FLINK-37108) Source/Sink test suites test invalid recovery

2025-02-08 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-37108. - Fix Version/s: 2.0.0 1.19.2 1.20.1 Resolution: Fixed

[jira] [Updated] (FLINK-37287) There was Apache Paimon 0.9, but it is gone.

2025-02-08 Thread 911432 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 911432 updated FLINK-37287: --- Fix Version/s: cdc-3.4.0 > There was Apache Paimon 0.9, but it is gone. > --

[jira] [Commented] (FLINK-37287) There was Apache Paimon 0.9, but it is gone.

2025-02-08 Thread 911432 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925290#comment-17925290 ] 911432 commented on FLINK-37287: [~kunni] There was Apache Paimon 0.9, but it's gone. I

[jira] [Updated] (FLINK-37287) There was Apache Paimon 0.9, but it is gone.

2025-02-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37287: --- Labels: pull-request-available (was: ) > There was Apache Paimon 0.9, but it is gone. > ---

[PR] [FLINK-37287][docs] Adding Apache Paimon 0.9 [flink-cdc]

2025-02-08 Thread via GitHub
911432 opened a new pull request, #3913: URL: https://github.com/apache/flink-cdc/pull/3913 There was Apache Paimon 0.9, but it's gone. I try to add Apache Paimon 0.9 on overview.md. -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[jira] [Updated] (FLINK-37254) Flink CDC OceanBase Connector Throws Exception for Column Default Value ‘DEFAULT ‘0’

2025-02-08 Thread caixiaowei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caixiaowei updated FLINK-37254: --- Priority: Blocker (was: Major) > Flink CDC OceanBase Connector Throws Exception for Column Default

[jira] [Created] (FLINK-37287) There was Apache Paimon 0.9, but it is gone.

2025-02-08 Thread 911432 (Jira)
911432 created FLINK-37287: -- Summary: There was Apache Paimon 0.9, but it is gone. Key: FLINK-37287 URL: https://issues.apache.org/jira/browse/FLINK-37287 Project: Flink Issue Type: Improvement

Re: [PR] [hotfix][state/rocksdb] Use try-with-resources to close RocksStateKeysIterator and fix some typos. [flink]

2025-02-08 Thread via GitHub
littleeleventhwolf commented on PR #26126: URL: https://github.com/apache/flink/pull/26126#issuecomment-2645735478 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-37267][table] Add support for UNNEST WITH ORDINALITY [flink]

2025-02-08 Thread via GitHub
gustavodemorais commented on PR #26113: URL: https://github.com/apache/flink/pull/26113#issuecomment-2645664649 Apart from addressing the minor comments, I've made the changes to support arrays and multisets of rows, following Calcite's implementation. Also added several tests for mu

Re: [PR] [hotfix] Remove inappropriate annotation in `flink-statebackend-forst` [flink]

2025-02-08 Thread via GitHub
Zakelly merged PR #26123: URL: https://github.com/apache/flink/pull/26123 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

Re: [PR] [BP-2.0][hotfix] Remove inappropriate annotation in `flink-statebackend-forst` [flink]

2025-02-08 Thread via GitHub
Zakelly merged PR #26124: URL: https://github.com/apache/flink/pull/26124 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

[jira] [Commented] (FLINK-37286) Introduce ClickHouseDialect And ClickHouseCatalog

2025-02-08 Thread Chaojian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925209#comment-17925209 ] Chaojian Fu commented on FLINK-37286: - Hi [~felixzheng], Could you help to assign th

Re: [PR] [FLINK-37225] Remove remaining test resources of Gelly [flink]

2025-02-08 Thread via GitHub
X-czh commented on PR #26081: URL: https://github.com/apache/flink/pull/26081#issuecomment-2644881239 @davidradl I'm not familiar with the background either, it is removed in Flink 1.16. @MartijnVisser Maybe you can provide more background here -- This is an automated message from the Apa

Re: [PR] [FLINK-36352][doc] Remove Scala DataStream API related doc [flink]

2025-02-08 Thread via GitHub
X-czh commented on PR #26082: URL: https://github.com/apache/flink/pull/26082#issuecomment-2644874905 @codenohup Thanks for the review, squashed the commits. @reswqa Could you help take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Created] (FLINK-37286) Introduce ClickHouseDialect And ClickHouseCatalog

2025-02-08 Thread Chaojian Fu (Jira)
Chaojian Fu created FLINK-37286: --- Summary: Introduce ClickHouseDialect And ClickHouseCatalog Key: FLINK-37286 URL: https://issues.apache.org/jira/browse/FLINK-37286 Project: Flink Issue Type: S

Re: [PR] [FLINK-37278] Optimize regular schema evolution topology's performance [flink-cdc]

2025-02-08 Thread via GitHub
yuxiqian commented on PR #3912: URL: https://github.com/apache/flink-cdc/pull/3912#issuecomment-2644730353 Would @hiliuxg like to take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the