Re: [PR] [FLINK-37224] Add the missing documents and parameters of MongoDB CDC. [flink-cdc]

lvyanquan commented on PR #3895: URL: https://github.com/apache/flink-cdc/pull/3895#issuecomment-2613834733 Hi @leonardBang. PTAL. -- 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

[jira] [Closed] (FLINK-37210) Add flink-cdc-release-3.3.0 module to flink-cdc-migration-tests.

[ https://issues.apache.org/jira/browse/FLINK-37210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv closed FLINK-37210. -- Resolution: Fixed > Add flink-cdc-release-3.3.0 module to flink-cdc-migration-tests. > ---

[jira] [Commented] (FLINK-37224) Add the missing content of MongoDB CDC to the Chinese document.

[ https://issues.apache.org/jira/browse/FLINK-37224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916902#comment-17916902 ] Yanquan Lv commented on FLINK-37224: I would like to take this. > Add the missing c

Re: [PR] FLINK-37154: Adding SimpleByteSchema for PyFlink [flink]

christeoh commented on PR #26080: URL: https://github.com/apache/flink/pull/26080#issuecomment-2613923438 @flinkbot run azure Get Outlook for Android From: flinkbot ***@***.***> Sent: Saturday, January 25, 2025 6:43:28 P

[jira] [Updated] (FLINK-37224) Add the missing content of MongoDB CDC to the Chinese document.

[ https://issues.apache.org/jira/browse/FLINK-37224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37224: --- Labels: pull-request-available (was: ) > Add the missing content of MongoDB CDC to the Chin

[jira] [Commented] (FLINK-37210) Add flink-cdc-release-3.3.0 module to flink-cdc-migration-tests.

[ https://issues.apache.org/jira/browse/FLINK-37210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916903#comment-17916903 ] Yanquan Lv commented on FLINK-37210: Closed by https://github.com/apache/flink-cdc/p

Re: [PR] FLINK-37154: Adding SimpleByteSchema for PyFlink [flink]

christeoh commented on PR #26080: URL: https://github.com/apache/flink/pull/26080#issuecomment-2613933343 @flinkbot run azure From: flinkbot ***@***.***> Sent: Saturday, 25 January 2025 6:43 PM To: apache/flink ***@***.***> Cc: Chris ***@***.***

[jira] [Updated] (FLINK-37225) Remove remaining test resources of Gelly

[ https://issues.apache.org/jira/browse/FLINK-37225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37225: -- Description: Some test resources of Gelly remained after FLINK-29668. !image-2025-01-26-09-34

[jira] [Created] (FLINK-37225) Remove remaining test resources of Gelly

Zhanghao Chen created FLINK-37225: - Summary: Remove remaining test resources of Gelly Key: FLINK-37225 URL: https://issues.apache.org/jira/browse/FLINK-37225 Project: Flink Issue Type: Techni

[jira] [Updated] (FLINK-37225) Remove remaining test resources of Gelly

[ https://issues.apache.org/jira/browse/FLINK-37225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37225: --- Labels: pull-request-available (was: ) > Remove remaining test resources of Gelly > ---

[jira] [Commented] (FLINK-36659) Release flink-connector-jdbc vx.x.x for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916992#comment-17916992 ] Yanquan Lv commented on FLINK-36659: I'm willing to take this. > Release flink-conn

Re: [PR] [FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder [flink]

jiefei30 commented on PR #25946: URL: https://github.com/apache/flink/pull/25946#issuecomment-2614184974 cc @fsk119 please help review this PR when you are free. Thank you very much. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Updated] (FLINK-36352) Remove scala `Datastream` in docs

[ https://issues.apache.org/jira/browse/FLINK-36352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36352: --- Labels: pull-request-available (was: ) > Remove scala `Datastream` in docs > --

Re: [PR] [FLINK-37223] Add the missing documents and parameters of MySQL CDC. [flink-cdc]

ChaomingZhangCN commented on code in PR #3894: URL: https://github.com/apache/flink-cdc/pull/3894#discussion_r1929645059 ## docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md: ## @@ -422,6 +434,11 @@ Flink SQL> SELECT * FROM orders; TIMESTAMP_LTZ(3) NOT NULL

Re: [PR] [FLINK-36696] [flink-autoscaler-plugin-jdbc] Switch sql connection usages to datasource [flink-kubernetes-operator]

1996fanrui commented on PR #929: URL: https://github.com/apache/flink-kubernetes-operator/pull/929#issuecomment-2614195894 One test fails since ` too many clients already`, I'm not sure is there any client or connection leak? ``` Error: Tests run: 17, Failures: 0, Errors: 1, Skip

[jira] [Created] (FLINK-37226) Replace deprecated methods in the DataStream API introduction doc

Zhanghao Chen created FLINK-37226: - Summary: Replace deprecated methods in the DataStream API introduction doc Key: FLINK-37226 URL: https://issues.apache.org/jira/browse/FLINK-37226 Project: Flink

Re: [PR] [FLINK-37121][docs] Fix syntax and examples in create table statement doc [flink]

jiefei30 commented on PR #25982: URL: https://github.com/apache/flink/pull/25982#issuecomment-2614199435 @davidradl . I added some text to link to the materialized table grammar and temporary table description. I also built the docs on my mac and check the link are all right. -- This is

[jira] [Updated] (FLINK-36659) Release flink-connector-jdbc vx.x.x for Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-36659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36659: --- Labels: pull-request-available (was: ) > Release flink-connector-jdbc vx.x.x for Flink 2.0

Re: [PR] [FLINK-36659] Bump to 2.0-preview1. [flink-connector-jdbc]

boring-cyborg[bot] commented on PR #153: URL: https://github.com/apache/flink-connector-jdbc/pull/153#issuecomment-2614167996 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-37225] Remove remaining test resources of Gelly [flink]

flinkbot commented on PR #26081: URL: https://github.com/apache/flink/pull/26081#issuecomment-2614173052 ## CI report: * c42c4ee7a8e1fac1fec23c97867b64af9801b356 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

flinkbot commented on PR #26082: URL: https://github.com/apache/flink/pull/26082#issuecomment-2614189976 ## CI report: * 2e7c0eaa0cf87047681925dc1eea1f13a79efb39 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-37047) Cross-team verification for "Remove DataSet API"

[ https://issues.apache.org/jira/browse/FLINK-37047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17917007#comment-17917007 ] Zhanghao Chen commented on FLINK-37047: --- Hi [~yyhx], I've noticed two potential is

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

X-czh opened a new pull request, #26082: URL: https://github.com/apache/flink/pull/26082 ## What is the purpose of the change Remove Scala DataStream API related doc. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

Re: [PR] [FLINK-37087][doc] Add docs for alter materialized table as query [flink]

hackergin commented on PR #26064: URL: https://github.com/apache/flink/pull/26064#issuecomment-2614251095 > I see that the REFRESH keyword is mentioned - there is a some explanation of this in the file but not how the partition piece works and when you would want to use it. I see we have ad

Re: [PR] [FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors [flink]

JoeryH commented on PR #26029: URL: https://github.com/apache/flink/pull/26029#issuecomment-2614063081 @davidradl I added an unit test -- 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] fixup! (1.19 backport) [FLINK-35886][task] Fix watermark idleness timeout accounting when subtask is backpressured/blocked [flink]

afedulov commented on code in PR #25245: URL: https://github.com/apache/flink/pull/25245#discussion_r1929621095 ## pom.xml: ## @@ -2355,8 +2355,6 @@ under the License. @org.apache.flink.annotation.Experimental

[jira] [Commented] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916974#comment-17916974 ] Alexander Fedulov commented on FLINK-35886: --- [~pnowojski] unfortunately [this|

[jira] [Comment Edited] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916974#comment-17916974 ] Alexander Fedulov edited comment on FLINK-35886 at 1/25/25 10:43 PM: -

[jira] [Comment Edited] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916974#comment-17916974 ] Alexander Fedulov edited comment on FLINK-35886 at 1/25/25 10:52 PM: -

Re: [PR] fixup! (1.19 backport) [FLINK-35886][task] Fix watermark idleness timeout accounting when subtask is backpressured/blocked [flink]

afedulov commented on code in PR #25245: URL: https://github.com/apache/flink/pull/25245#discussion_r1929621095 ## pom.xml: ## @@ -2355,8 +2355,6 @@ under the License. @org.apache.flink.annotation.Experimental

[jira] [Comment Edited] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916974#comment-17916974 ] Alexander Fedulov edited comment on FLINK-35886 at 1/25/25 10:54 PM: -

[jira] [Comment Edited] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916975#comment-17916975 ] Alexander Fedulov edited comment on FLINK-35886 at 1/25/25 11:06 PM: -

[jira] [Commented] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916975#comment-17916975 ] Alexander Fedulov commented on FLINK-35886: --- It seems that this commit is miss

[jira] [Comment Edited] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916975#comment-17916975 ] Alexander Fedulov edited comment on FLINK-35886 at 1/25/25 11:06 PM: -

[jira] [Comment Edited] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916975#comment-17916975 ] Alexander Fedulov edited comment on FLINK-35886 at 1/25/25 11:08 PM: -

[jira] [Comment Edited] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916975#comment-17916975 ] Alexander Fedulov edited comment on FLINK-35886 at 1/25/25 11:08 PM: -

[jira] [Comment Edited] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916975#comment-17916975 ] Alexander Fedulov edited comment on FLINK-35886 at 1/25/25 11:09 PM: -

[jira] [Comment Edited] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916975#comment-17916975 ] Alexander Fedulov edited comment on FLINK-35886 at 1/25/25 11:08 PM: -

[jira] [Commented] (FLINK-37186) Cross-team verification for "FLIP-480: Support to deploy SQL script in application mode"

[ https://issues.apache.org/jira/browse/FLINK-37186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17917004#comment-17917004 ] Feng Jin commented on FLINK-37186: -- I'd like to verify this feature. > Cross-team veri

[jira] [Commented] (FLINK-37049) Cross-team verification for "Remove all Scala APIs"

[ https://issues.apache.org/jira/browse/FLINK-37049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17917005#comment-17917005 ] Zhanghao Chen commented on FLINK-37049: --- [~yyhx] I confirmed that the DS Scala API

Re: [PR] FLINK-37154: Adding SimpleByteSchema for PyFlink [flink]

christeoh commented on PR #26080: URL: https://github.com/apache/flink/pull/26080#issuecomment-2614196410 @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 comment.

[jira] [Updated] (FLINK-37134) Cross-team verification for FLIP-492

[ https://issues.apache.org/jira/browse/FLINK-37134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jin updated FLINK-37134: - Description: This is for cross-team verification of the release 2.0 work item: [https://cwiki.apache.or

[jira] [Commented] (FLINK-37118) Enhance flink cdc metrics

[ https://issues.apache.org/jira/browse/FLINK-37118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17917006#comment-17917006 ] ChaomingZhang commented on FLINK-37118: --- [~melin] What a nice feature! In my opini

Re: [PR] [FLINK-36696] [flink-autoscaler-plugin-jdbc] Switch sql connection usages to datasource [flink-kubernetes-operator]

1996fanrui commented on code in PR #929: URL: https://github.com/apache/flink-kubernetes-operator/pull/929#discussion_r1929653819 ## flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/testutils/databases/postgres/PostgreSQLExtension.java: ## @@ -66,7 +7

Re: [PR] [FLINK-37087][doc] Add docs for alter materialized table as query [flink]

lsyldliu commented on code in PR #26064: URL: https://github.com/apache/flink/pull/26064#discussion_r1929664176 ## docs/content/docs/dev/table/materialized-table/statements.md: ## @@ -326,6 +328,69 @@ ALTER MATERIALIZED TABLE my_materialized_table REFRESH PARTITION (ds='2024-06

[jira] [Commented] (FLINK-37225) Remove remaining test resources of Gelly

[ https://issues.apache.org/jira/browse/FLINK-37225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17917021#comment-17917021 ] Zhanghao Chen commented on FLINK-37225: --- [~martijnvisser] Could you help take a lo