[jira] [Resolved] (FLINK-18255) Add API annotations to RocksDB user-facing classes

2024-03-14 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-18255. -- Resolution: Fixed merged 8fba491c into master. > Add API annotations to RocksDB user-facing

Re: [PR] [FLINK-18255][state] Add API annotations to RocksDB user-facing classes [flink]

2024-03-14 Thread via GitHub
masteryhx closed pull request #24496: [FLINK-18255][state] Add API annotations to RocksDB user-facing classes URL: https://github.com/apache/flink/pull/24496 -- 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

[jira] [Closed] (FLINK-34594) CLONE - Vote on the release candidate

2024-03-14 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34594. --- Resolution: Fixed vote result https://lists.apache.org/thread/stps3d8m6hsny5mglbr4h09879ny5nog >

[jira] [Assigned] (FLINK-34615) Move ExternalizedCheckpointCleanup to flink-core

2024-03-14 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-34615: --- Assignee: liuzhuo > Move ExternalizedCheckpointCleanup to flink-core >

[jira] [Resolved] (FLINK-34484) Split 'state.backend.local-recovery' into two options for checkpointing and recovery

2024-03-14 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-34484. - Resolution: Fixed > Split 'state.backend.local-recovery' into two options for checkpointing and

[jira] [Assigned] (FLINK-34516) Move CheckpointingMode to flink-core

2024-03-14 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-34516: --- Assignee: Zakelly Lan > Move CheckpointingMode to flink-core >

[jira] [Updated] (FLINK-34690) If data from upstream is decimal and primary key , starrocks sink will not support.

2024-03-14 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-34690: -- Description: Flink only have bigint type, if mysql data is unsigned bigint , maybe out of

[jira] [Created] (FLINK-34690) If data from upstream is decimal and primary key , starrocks sink will not support.

2024-03-14 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-34690: - Summary: If data from upstream is decimal and primary key , starrocks sink will not support. Key: FLINK-34690 URL: https://issues.apache.org/jira/browse/FLINK-34690

Re: [PR] [MySQL][Feature] check binlog_row_value_optoins [flink-cdc]

2024-03-14 Thread via GitHub
SML0127 commented on PR #3148: URL: https://github.com/apache/flink-cdc/pull/3148#issuecomment-1998895031 jira issue: https://issues.apache.org/jira/browse/FLINK-34689 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Created] (FLINK-34689) check binlog_row_value_optoins

2024-03-14 Thread Lee SeungMin (Jira)
Lee SeungMin created FLINK-34689: Summary: check binlog_row_value_optoins Key: FLINK-34689 URL: https://issues.apache.org/jira/browse/FLINK-34689 Project: Flink Issue Type: Improvement

[PR] [MySQL][Feature] check binlog_row_value_optoins [flink-cdc]

2024-03-14 Thread via GitHub
SML0127 opened a new pull request, #3148: URL: https://github.com/apache/flink-cdc/pull/3148 Implemented functino to check `binlog_row_value_optoins` within MySqlValidator. When `binlog_row_value_optoins` is set to `PARTIAL_JSON`, the update operator remains as 

Re: [PR] [MySQL][Feature] Check binlog row value options [flink-cdc]

2024-03-14 Thread via GitHub
SML0127 closed pull request #3147: [MySQL][Feature] Check binlog row value options URL: https://github.com/apache/flink-cdc/pull/3147 -- 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

[PR] [MySQL][Feature] Check binlog row value options [flink-cdc]

2024-03-14 Thread via GitHub
SML0127 opened a new pull request, #3147: URL: https://github.com/apache/flink-cdc/pull/3147 Implemented functino to check `binlog_row_value_optoins` within MySqlValidator. When `binlog_row_value_optoins` is set to `PARTIAL_JSON`, the update operator remains as

Re: [PR] [Flink 34569][e2e] fail fast if AWS cli container fails to start [flink]

2024-03-14 Thread via GitHub
robobario commented on code in PR #24491: URL: https://github.com/apache/flink/pull/24491#discussion_r1525716429 ## flink-end-to-end-tests/test-scripts/common_s3_operations.sh: ## @@ -58,7 +64,11 @@ function aws_cli_stop() { if [[ $AWSCLI_CONTAINER_ID ]]; then aws_cli_stop

Re: [PR] [FLINK-34677][cdc] Refactor the structure of Flink CDC documentation [flink-cdc]

2024-03-14 Thread via GitHub
hirolee88 commented on code in PR #3146: URL: https://github.com/apache/flink-cdc/pull/3146#discussion_r1525714223 ## docs/content/docs/connectors/legacy-flink-cdc-sources/oceanbase-cdc.md: ## @@ -154,7 +154,7 @@ Flink SQL> CREATE TABLE orders ( ); ``` -You can also try the

[jira] [Commented] (FLINK-34677) Refactor the structure of documentation for Flink CDC

2024-03-14 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827336#comment-17827336 ] Zhongqiang Gong commented on FLINK-34677: - [~renqs] Should add sub task to change `With Flink

[jira] [Assigned] (FLINK-34682) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34682: - Assignee: Qingsheng Ren > "Developer Guide - Understanding Flink CDC API" Page for

[jira] [Updated] (FLINK-34682) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34682: -- Summary: "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Documentation

[jira] [Assigned] (FLINK-34678) "Introduction" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34678: - Assignee: Qingsheng Ren > "Introduction" Page for Flink CDC Documentation >

[jira] [Assigned] (FLINK-34679) "Core Concept" Pages for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34679: - Assignee: LvYanquan > "Core Concept" Pages for Flink CDC Documentation >

[jira] [Commented] (FLINK-34688) CDC framework split snapshot chunks asynchronously

2024-03-14 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827335#comment-17827335 ] Hongshun Wang commented on FLINK-34688: --- Please assign it to me. > CDC framework split snapshot

[jira] [Commented] (FLINK-34666) Keep assigned splits in order to fix wrong meta group calculation

2024-03-14 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827333#comment-17827333 ] Hongshun Wang commented on FLINK-34666: --- Please assign it to me. > Keep assigned splits in order

[jira] [Updated] (FLINK-34677) Refactor the structure of documentation for Flink CDC

2024-03-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34677: --- Labels: pull-request-available (was: ) > Refactor the structure of documentation for Flink

[jira] [Commented] (FLINK-34634) Restarting the job will not read the changelog anymore if it stops before the synchronization of meta information is complete and some table is removed

2024-03-14 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827334#comment-17827334 ] Hongshun Wang commented on FLINK-34634: --- Please assign it to me. > Restarting the job will not

[PR] [FLINK-34677][cdc] Refactor the structure of Flink CDC documentation [flink-cdc]

2024-03-14 Thread via GitHub
PatrickRen opened a new pull request, #3146: URL: https://github.com/apache/flink-cdc/pull/3146 This pull request refactors the structure of Flink CDC documentation. Some pages are left blank and will be filled up by following PRs. -- This is an automated message from the Apache Git

[jira] [Created] (FLINK-34688) CDC framework split snapshot chunks asynchronously

2024-03-14 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-34688: - Summary: CDC framework split snapshot chunks asynchronously Key: FLINK-34688 URL: https://issues.apache.org/jira/browse/FLINK-34688 Project: Flink Issue

[jira] [Commented] (FLINK-34679) "Core Concept" Pages for Flink CDC Documentation

2024-03-14 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827332#comment-17827332 ] LvYanquan commented on FLINK-34679: --- I'm willing to take this. > "Core Concept" Pages for Flink CDC

[jira] [Assigned] (FLINK-34684) "Developer Guide - Licenses" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34684: - Assignee: Hang Ruan > "Developer Guide - Licenses" Page for Flink CDC Documentation >

[jira] [Created] (FLINK-34687) Home Page of Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34687: - Summary: Home Page of Flink CDC Documentation Key: FLINK-34687 URL: https://issues.apache.org/jira/browse/FLINK-34687 Project: Flink Issue Type: Sub-task

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

2024-03-14 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827331#comment-17827331 ] Yanfei Lei commented on FLINK-34581: Hi [~henning], it looks like it's caused by Java setting, have

[jira] [Commented] (FLINK-34684) "Developer Guide - Licenses" Page for Flink CDC Documentation

2024-03-14 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827329#comment-17827329 ] Hang Ruan commented on FLINK-34684: --- I would like to help on this issue. Please assign this to me.

Re: [PR] [FLINK-32074][checkpoint] Merge file across checkpoints [flink]

2024-03-14 Thread via GitHub
Zakelly commented on code in PR #24497: URL: https://github.com/apache/flink/pull/24497#discussion_r1525707616 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingType.java: ## @@ -0,0 +1,29 @@ +/* + * Licensed to the Apache Software

[jira] [Created] (FLINK-34686) "Deployment - YARN" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34686: - Summary: "Deployment - YARN" Page for Flink CDC Documentation Key: FLINK-34686 URL: https://issues.apache.org/jira/browse/FLINK-34686 Project: Flink Issue

[jira] [Created] (FLINK-34685) "Deployment - Kubernetes" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34685: - Summary: "Deployment - Kubernetes" Page for Flink CDC Documentation Key: FLINK-34685 URL: https://issues.apache.org/jira/browse/FLINK-34685 Project: Flink

[jira] [Updated] (FLINK-34683) "Developer Guide - Contribute to Flink CDC" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34683: -- Fix Version/s: cdc-3.1.0 (was: 3.1.0) > "Developer Guide - Contribute

[jira] [Updated] (FLINK-34681) "Deployment - Standalone" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34681: -- Summary: "Deployment - Standalone" Page for Flink CDC Documentation (was: "Deployment" Pages

[jira] [Updated] (FLINK-34653) Support table merging with route in Flink CDC

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34653: -- Fix Version/s: cdc-3.1.0 (was: 3.1.0) > Support table merging with

[jira] [Updated] (FLINK-34677) Refactor the structure of documentation for Flink CDC

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34677: -- Description: The documentation structure of Flink CDC is not quite in good shape currently.

[jira] [Updated] (FLINK-34682) "Developer Guide - Understanding Flink CDC" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34682: -- Affects Version/s: cdc-3.1.0 (was: 3.1.0) > "Developer Guide -

[jira] [Updated] (FLINK-34680) "Connectors - Overview" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34680: -- Affects Version/s: cdc-3.1.0 (was: 3.1.0) > "Connectors -

[jira] [Updated] (FLINK-34681) "Deployment" Pages for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34681: -- Fix Version/s: cdc-3.1.0 (was: 3.1.0) > "Deployment" Pages for Flink

[jira] [Updated] (FLINK-34682) "Developer Guide - Understanding Flink CDC" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34682: -- Fix Version/s: cdc-3.1.0 (was: 3.1.0) > "Developer Guide -

[jira] [Updated] (FLINK-34683) "Developer Guide - Contribute to Flink CDC" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34683: -- Affects Version/s: cdc-3.1.0 (was: 3.1.0) > "Developer Guide -

[jira] [Updated] (FLINK-34681) "Deployment" Pages for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34681: -- Affects Version/s: cdc-3.1.0 (was: 3.1.0) > "Deployment" Pages for

[jira] [Updated] (FLINK-34680) "Connectors - Overview" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34680: -- Summary: "Connectors - Overview" Page for Flink CDC Documentation (was: "Overview" Page for

[jira] [Updated] (FLINK-34680) "Connectors - Overview" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34680: -- Fix Version/s: cdc-3.1.0 (was: 3.1.0) > "Connectors - Overview" Page

[jira] [Updated] (FLINK-34679) "Core Concept" Pages for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34679: -- Affects Version/s: cdc-3.1.0 (was: 3.1.0) > "Core Concept" Pages

[jira] [Updated] (FLINK-34678) "Introduction" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34678: -- Fix Version/s: cdc-3.1.0 (was: 3.1.0) > "Introduction" Page for Flink

[jira] [Updated] (FLINK-34677) Refactor the structure of documentation for Flink CDC

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34677: -- Affects Version/s: cdc-3.1.0 (was: 3.1.0) > Refactor the structure

[jira] [Updated] (FLINK-34678) "Introduction" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34678: -- Affects Version/s: cdc-3.1.0 (was: 3.1.0) > "Introduction" Page

[jira] [Updated] (FLINK-34677) Refactor the structure of documentation for Flink CDC

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34677: -- Fix Version/s: cdc-3.1.0 (was: 3.1.0) > Refactor the structure of

[jira] [Updated] (FLINK-34679) "Core Concept" Pages for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34679: -- Fix Version/s: cdc-3.1.0 (was: 3.1.0) > "Core Concept" Pages for Flink

[jira] [Created] (FLINK-34684) "Developer Guide - Licenses" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34684: - Summary: "Developer Guide - Licenses" Page for Flink CDC Documentation Key: FLINK-34684 URL: https://issues.apache.org/jira/browse/FLINK-34684 Project: Flink

[jira] [Created] (FLINK-34683) "Developer Guide - Contribute to Flink CDC" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34683: - Summary: "Developer Guide - Contribute to Flink CDC" Page for Flink CDC Documentation Key: FLINK-34683 URL: https://issues.apache.org/jira/browse/FLINK-34683

[jira] [Created] (FLINK-34682) "Developer Guide - Understanding Flink CDC" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34682: - Summary: "Developer Guide - Understanding Flink CDC" Page for Flink CDC Documentation Key: FLINK-34682 URL: https://issues.apache.org/jira/browse/FLINK-34682

[jira] [Created] (FLINK-34681) "Deployment" Pages for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34681: - Summary: "Deployment" Pages for Flink CDC Documentation Key: FLINK-34681 URL: https://issues.apache.org/jira/browse/FLINK-34681 Project: Flink Issue Type:

[jira] [Created] (FLINK-34680) "Overview" Page for Connectors in Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34680: - Summary: "Overview" Page for Connectors in Flink CDC Documentation Key: FLINK-34680 URL: https://issues.apache.org/jira/browse/FLINK-34680 Project: Flink

[jira] [Created] (FLINK-34679) "Core Concept" Pages for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34679: - Summary: "Core Concept" Pages for Flink CDC Documentation Key: FLINK-34679 URL: https://issues.apache.org/jira/browse/FLINK-34679 Project: Flink Issue

[jira] [Created] (FLINK-34678) "Introduction" Page for Flink CDC Documentation

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34678: - Summary: "Introduction" Page for Flink CDC Documentation Key: FLINK-34678 URL: https://issues.apache.org/jira/browse/FLINK-34678 Project: Flink Issue

[jira] [Created] (FLINK-34677) Refactor the structure of documentation for Flink CDC

2024-03-14 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-34677: - Summary: Refactor the structure of documentation for Flink CDC Key: FLINK-34677 URL: https://issues.apache.org/jira/browse/FLINK-34677 Project: Flink

Re: [PR] [FLINK-32074][checkpoint] Merge file across checkpoints [flink]

2024-03-14 Thread via GitHub
masteryhx commented on code in PR #24497: URL: https://github.com/apache/flink/pull/24497#discussion_r1525686649 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/AcrossCheckpointFileMergingSnapshotManager.java: ## @@ -0,0 +1,69 @@ +/* + * Licensed

[jira] [Resolved] (FLINK-34389) JdbcAutoscalerStateStore explicitly writes update_time

2024-03-14 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34389. - Fix Version/s: kubernetes-operator-1.8.0 (was: kubernetes-operator-1.9.0)

[jira] [Commented] (FLINK-34389) JdbcAutoscalerStateStore explicitly writes update_time

2024-03-14 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827318#comment-17827318 ] Rui Fan commented on FLINK-34389: - Merged to main(1.8.0) via: 733b1b54e23c7486418bdca706f85a97b896f469

Re: [PR] [FLINK-32074][checkpoint] Merge file across checkpoints [flink]

2024-03-14 Thread via GitHub
Zakelly commented on PR #24497: URL: https://github.com/apache/flink/pull/24497#issuecomment-1998818071 Hi @fredia @masteryhx , would you please take a look? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [FLINK-34517][table]fix environment configs ignored when calling procedure operation [flink]

2024-03-14 Thread via GitHub
luoyuxia commented on PR #24397: URL: https://github.com/apache/flink/pull/24397#issuecomment-1998736348 @JustinLeesin Could you please cherry pick it to release-1.19 branch? And if ci passed, please let me know -- This is an automated message from the Apache Git Service. To respond to

Re: [PR] [hotfix] Change old com.ververica dependency to flink [flink-cdc]

2024-03-14 Thread via GitHub
xleoken commented on PR #3110: URL: https://github.com/apache/flink-cdc/pull/3110#issuecomment-1998693540 cc @leonardBang @PatrickRen @Jiabao-Sun -- 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

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-14 Thread via GitHub
rkhachatryan commented on code in PR #24484: URL: https://github.com/apache/flink/pull/24484#discussion_r1525601102 ## flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java: ## @@ -116,18 +116,55 @@ public void testJobIDLogging(@InjectClusterClient

Re: [PR] [FLINK-34676][table] Migrate ConvertToNotInOrInRule to java [flink]

2024-03-14 Thread via GitHub
flinkbot commented on PR #24503: URL: https://github.com/apache/flink/pull/24503#issuecomment-1998629434 ## CI report: * d48a09a1ce520c37f2b4d76800788721318c6571 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34676) Migrate ConvertToNotInOrInRule

2024-03-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34676: --- Labels: pull-request-available (was: ) > Migrate ConvertToNotInOrInRule >

[PR] [FLINK-34676][table] Migrate ConvertToNotInOrInRule to java [flink]

2024-03-14 Thread via GitHub
snuyanzin opened a new pull request, #24503: URL: https://github.com/apache/flink/pull/24503 ## What is the purpose of the change A bit reasoning for the change >The reason is that since 1.28.0 ( [CALCITE-4787](https://issues.apache.org/jira/browse/CALCITE-4787) - Move core

[jira] [Created] (FLINK-34676) Migrate ConvertToNotInOrInRule

2024-03-14 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34676: --- Summary: Migrate ConvertToNotInOrInRule Key: FLINK-34676 URL: https://issues.apache.org/jira/browse/FLINK-34676 Project: Flink Issue Type: Sub-task

Re: [PR] [FLINK-34675][table] Migrate AggregateReduceGroupingRule to java [flink]

2024-03-14 Thread via GitHub
flinkbot commented on PR #24502: URL: https://github.com/apache/flink/pull/24502#issuecomment-1998611238 ## CI report: * 28da034cfeac05324128e4a5334d40029fc72208 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34675) Migrate AggregateReduceGroupingRule

2024-03-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34675: --- Labels: pull-request-available (was: ) > Migrate AggregateReduceGroupingRule >

[PR] [FLINK-34675][table] Migrate AggregateReduceGroupingRule to java [flink]

2024-03-14 Thread via GitHub
snuyanzin opened a new pull request, #24502: URL: https://github.com/apache/flink/pull/24502 ## What is the purpose of the change A bit reasoning for the change >The reason is that since 1.28.0 ( [CALCITE-4787](https://issues.apache.org/jira/browse/CALCITE-4787) - Move core

[jira] [Created] (FLINK-34675) Migrate AggregateReduceGroupingRule

2024-03-14 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34675: --- Summary: Migrate AggregateReduceGroupingRule Key: FLINK-34675 URL: https://issues.apache.org/jira/browse/FLINK-34675 Project: Flink Issue Type:

Re: [PR] [FLINK-34674][table] Migrate CalcSnapshotTransposeRule to java [flink]

2024-03-14 Thread via GitHub
flinkbot commented on PR #24501: URL: https://github.com/apache/flink/pull/24501#issuecomment-1998563062 ## CI report: * 9d8ed138d96a70e53bbdaf34528ca97d90793c1b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34674) Migrate CalcSnapshotTransposeRule

2024-03-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34674: --- Labels: pull-request-available (was: ) > Migrate CalcSnapshotTransposeRule >

[PR] [FLINK-34674][table] Migrate CalcSnapshotTransposeRule to java [flink]

2024-03-14 Thread via GitHub
snuyanzin opened a new pull request, #24501: URL: https://github.com/apache/flink/pull/24501 ## What is the purpose of the change A bit reasoning for the change >The reason is that since 1.28.0 ( [CALCITE-4787](https://issues.apache.org/jira/browse/CALCITE-4787) - Move core

[jira] [Created] (FLINK-34674) Migrate CalcSnapshotTransposeRule

2024-03-14 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34674: --- Summary: Migrate CalcSnapshotTransposeRule Key: FLINK-34674 URL: https://issues.apache.org/jira/browse/FLINK-34674 Project: Flink Issue Type: Sub-task

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-14 Thread via GitHub
rkhachatryan commented on code in PR #24484: URL: https://github.com/apache/flink/pull/24484#discussion_r1525466583 ## flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java: ## @@ -116,18 +116,55 @@ public void testJobIDLogging(@InjectClusterClient

Re: [PR] [Flink 34569][e2e] fail fast if AWS cli container fails to start [flink]

2024-03-14 Thread via GitHub
JingGe commented on code in PR #24491: URL: https://github.com/apache/flink/pull/24491#discussion_r1525296378 ## flink-end-to-end-tests/test-scripts/common_s3_operations.sh: ## @@ -58,7 +64,11 @@ function aws_cli_stop() { if [[ $AWSCLI_CONTAINER_ID ]]; then aws_cli_stop fi

Re: [PR] [Flink 34569][e2e] fail fast if AWS cli container fails to start [flink]

2024-03-14 Thread via GitHub
JingGe commented on code in PR #24491: URL: https://github.com/apache/flink/pull/24491#discussion_r1525296378 ## flink-end-to-end-tests/test-scripts/common_s3_operations.sh: ## @@ -58,7 +64,11 @@ function aws_cli_stop() { if [[ $AWSCLI_CONTAINER_ID ]]; then aws_cli_stop fi

[PR] [release] Adjust website for Kubernetes operator 1.8.0 release [flink-web]

2024-03-14 Thread via GitHub
mxm opened a new pull request, #726: URL: https://github.com/apache/flink-web/pull/726 Draft PR for the upcoming Kubernetes operator 1.8.0 release -- 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

[jira] [Commented] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions

2024-03-14 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827172#comment-17827172 ] Ryan Skraba commented on FLINK-34673: - While I normally dislike putting "Thread.sleep(...)" in a

Re: [PR] [FLINK-34546] Emit span with failure labels on failure in AdaptiveScheduler. [flink]

2024-03-14 Thread via GitHub
rkhachatryan commented on code in PR #24498: URL: https://github.com/apache/flink/pull/24498#discussion_r1525177267 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/JobFailureMetricReporter.java: ## @@ -0,0 +1,84 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-34546] Emit span with failure labels on failure in AdaptiveScheduler. [flink]

2024-03-14 Thread via GitHub
rkhachatryan commented on code in PR #24498: URL: https://github.com/apache/flink/pull/24498#discussion_r1525178958 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/JobFailureMetricReporter.java: ## @@ -0,0 +1,84 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-34546] Emit span with failure labels on failure in AdaptiveScheduler. [flink]

2024-03-14 Thread via GitHub
rkhachatryan commented on code in PR #24498: URL: https://github.com/apache/flink/pull/24498#discussion_r1525177267 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/JobFailureMetricReporter.java: ## @@ -0,0 +1,84 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-34660) AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError

2024-03-14 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827157#comment-17827157 ] Ryan Skraba commented on FLINK-34660: - *

Re: [PR] [FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework [flink]

2024-03-14 Thread via GitHub
XComp commented on code in PR #24471: URL: https://github.com/apache/flink/pull/24471#discussion_r1525110715 ## flink-end-to-end-tests/flink-batch-sql-test/src/test/java/org/apache/flink/sql/tests/BatchSQLTest.java: ## @@ -0,0 +1,124 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-14 Thread via GitHub
XComp commented on code in PR #24484: URL: https://github.com/apache/flink/pull/24484#discussion_r1525054790 ## flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java: ## @@ -116,18 +116,55 @@ public void testJobIDLogging(@InjectClusterClient

Re: [PR] [FLINK-34565] Enhance flink kubernetes configMap to accommodate additional configuration files [flink]

2024-03-14 Thread via GitHub
surendralilhore commented on PR #24428: URL: https://github.com/apache/flink/pull/24428#issuecomment-1997683267 Hi @zhuzhurk, Please can you review this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[PR] [release] Update version to 1.9-SNAPSHOT [flink-kubernetes-operator]

2024-03-14 Thread via GitHub
mxm opened a new pull request, #798: URL: https://github.com/apache/flink-kubernetes-operator/pull/798 This bumps the snapshot version for the 1.8 release. -- 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

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-14 Thread via GitHub
leonardBang commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1525013212 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,501 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date:

[jira] [Commented] (FLINK-34529) Projection cannot be pushed down through rank operator.

2024-03-14 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827128#comment-17827128 ] lincoln lee commented on FLINK-34529: - [~nilerzhou]  Sorry for my late response! I agree with

[jira] [Reopened] (FLINK-34660) AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError

2024-03-14 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-34660: --- > AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError >

[jira] [Updated] (FLINK-34669) Optimization of Arch Rules for Connector Constraints and Violation File Updates

2024-03-14 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-34669: -- Description: Description: Potential optimization within our Arch rules that could improve the

[jira] [Updated] (FLINK-34669) Optimization of Arch Rules for Connector Constraints and Violation File Updates

2024-03-14 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34669: -- Description: Description: Potential optimization within our Arch rules that could improve the

[jira] [Updated] (FLINK-34669) Optimization of Arch Rules for Connector Constraints and Violation File Updates

2024-03-14 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-34669: -- Description: Description: Potential optimization within our Arch rules that could improve the

[jira] [Commented] (FLINK-34660) AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError

2024-03-14 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827117#comment-17827117 ] Ryan Skraba commented on FLINK-34660: - On Github Actions, this might still fail: If I read

Re: [PR] [FLINK-25544][streaming][JUnit5 Migration] The runtime package of module flink-stream-java [flink]

2024-03-14 Thread via GitHub
Jiabao-Sun commented on PR #24483: URL: https://github.com/apache/flink/pull/24483#issuecomment-1997605670 @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

  1   2   3   >