[PR] [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable [flink-cdc]

GOODBOY008 opened a new pull request, #3331: URL: https://github.com/apache/flink-cdc/pull/3331 (no comment) -- 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

[jira] [Created] (FLINK-35387) PG CDC source support heart beat

Hongshun Wang created FLINK-35387: - Summary: PG CDC source support heart beat Key: FLINK-35387 URL: https://issues.apache.org/jira/browse/FLINK-35387 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35386: - Assignee: Zhongqiang Gong (was: Qingsheng Ren) > Build Flink CDC 3.1 Documentation

[jira] [Resolved] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35386. --- Resolution: Fixed > Build Flink CDC 3.1 Documentation and mark it as stable >

[jira] [Commented] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847155#comment-17847155 ] Qingsheng Ren commented on FLINK-35386: --- flink-cdc master:

Re: [PR] [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable [flink-cdc]

PatrickRen merged PR #3317: URL: https://github.com/apache/flink-cdc/pull/3317 -- 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:

Re: [PR] [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable [flink-cdc]

PatrickRen commented on PR #3317: URL: https://github.com/apache/flink-cdc/pull/3317#issuecomment-2116703527 > Is this pr will be merged after release vote passed? Yes. The documentation can be adjusted anytime -- This is an automated message from the Apache Git Service. To respond

[jira] [Assigned] (FLINK-35049) Implement List/Map Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35049: -- Assignee: Yanfei Lei > Implement List/Map Async State API for ForStStateBackend >

Re: [PR] [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable [flink-cdc]

PatrickRen merged PR #3330: URL: https://github.com/apache/flink-cdc/pull/3330 -- 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:

Re: [PR] [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable [flink-cdc]

PatrickRen commented on PR #3329: URL: https://github.com/apache/flink-cdc/pull/3329#issuecomment-2116680813 Already covered by #3330 -- 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

Re: [PR] [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable [flink-cdc]

PatrickRen closed pull request #3329: [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable URL: https://github.com/apache/flink-cdc/pull/3329 -- 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-35030][runtime] Introduce Epoch Manager under async execution [flink]

fredia merged PR #24748: URL: https://github.com/apache/flink/pull/24748 -- 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:

[PR] [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable [flink-cdc]

GOODBOY008 opened a new pull request, #3330: URL: https://github.com/apache/flink-cdc/pull/3330 (no comment) -- 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

Re: [PR] [FLINK-35351][checkpoint] Fix fail during restore from unaligned chec… [flink]

ldadima commented on code in PR #24784: URL: https://github.com/apache/flink/pull/24784#discussion_r1603118510 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointCustomRescaleITCase.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache

Re: [PR] [hotfix] Fix compilation error due to constructor removal of MockSourceReader [flink-benchmarks]

Zakelly merged PR #89: URL: https://github.com/apache/flink-benchmarks/pull/89 -- 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:

[jira] [Updated] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35386: --- Labels: pull-request-available (was: ) > Build Flink CDC 3.1 Documentation and mark it as

[PR] [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable [flink-cdc]

PatrickRen opened a new pull request, #3329: URL: https://github.com/apache/flink-cdc/pull/3329 This pull request configures GitHub Action to build release-3.1 documentation and mark it as stable. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

Qingsheng Ren created FLINK-35386: - Summary: Build Flink CDC 3.1 Documentation and mark it as stable Key: FLINK-35386 URL: https://issues.apache.org/jira/browse/FLINK-35386 Project: Flink

Re: [PR] Add release announcement for Flink CDC 3.1.0 [flink-web]

PatrickRen commented on code in PR #739: URL: https://github.com/apache/flink-web/pull/739#discussion_r1604319112 ## docs/content/posts/2024-MM-DD-release-cdc-3.1.0.md: ## @@ -0,0 +1,67 @@ +--- +title: "Apache Flink CDC 3.1.0 Release Announcement" +date:

Re: [PR] Add release announcement for Flink CDC 3.1.0 [flink-web]

PatrickRen commented on code in PR #739: URL: https://github.com/apache/flink-web/pull/739#discussion_r1604313283 ## docs/content/posts/2024-MM-DD-release-cdc-3.1.0.md: ## @@ -0,0 +1,67 @@ +--- +title: "Apache Flink CDC 3.1.0 Release Announcement" +date:

[jira] [Resolved] (FLINK-35309) Enable Notice file ci check and fix Notice

[ https://issues.apache.org/jira/browse/FLINK-35309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35309. --- Resolution: Fixed > Enable Notice file ci check and fix Notice >

[jira] [Updated] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

[ https://issues.apache.org/jira/browse/FLINK-34990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34990: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) >

[jira] [Closed] (FLINK-34912) Replace all occurrences of com.ververica in the project with org.apache.flink

[ https://issues.apache.org/jira/browse/FLINK-34912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-34912. - Resolution: Duplicate > Replace all occurrences of com.ververica in the project with

[jira] [Updated] (FLINK-34908) [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost precision for timestamp

[ https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34908: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > [Feature][Pipeline] Mysql

[jira] [Updated] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.

[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34904: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > [Feature] submit Flink CDC

[jira] [Assigned] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34752: - Assignee: 牛一凡 > "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese

[jira] [Updated] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34752: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Updated] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34750: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Assigned] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34750: - Assignee: Hongshun Wang > "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC

[jira] [Updated] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34748: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Updated] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34749: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Assigned] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34748: - Assignee: 牛一凡 > "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese

[jira] [Updated] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34747: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Assigned] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34749: - Assignee: 牛一凡 > "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese >

[jira] [Assigned] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34747: - Assignee: Xiao Huang > "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese

Re: [PR] [FLINK-35047][state] Shutdown StateExecutors when ForStKeyedStateBackend is disposed [flink]

ljz2051 commented on code in PR #24768: URL: https://github.com/apache/flink/pull/24768#discussion_r1604301920 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackend.java: ## @@ -147,15 +160,30 @@ public S

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

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

[jira] [Assigned] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34736: - Assignee: Vincent Woo > "Deployment - Standalone" Page for Flink CDC Chinese

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

[ https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34736: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Deployment - Standalone"

[jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese

[ https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34730: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Translate pages of Flink

[jira] [Updated] (FLINK-35354) Support host mapping in Flink tikv cdc

[ https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35354: -- Fix Version/s: (was: cdc-3.1.0) > Support host mapping in Flink tikv cdc >

[jira] [Resolved] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35259. --- Resolution: Fixed > FlinkCDC Pipeline transform can't deal timestamp field >

[jira] [Comment Edited] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841824#comment-17841824 ] Qingsheng Ren edited comment on FLINK-35259 at 5/17/24 3:24 AM:

[jira] [Updated] (FLINK-34944) Use Incremental Source Framework in Flink CDC OceanBase Source Connector

[ https://issues.apache.org/jira/browse/FLINK-34944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34944: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Use Incremental Source

[jira] [Assigned] (FLINK-34944) Use Incremental Source Framework in Flink CDC OceanBase Source Connector

[ https://issues.apache.org/jira/browse/FLINK-34944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34944: - Assignee: He Wang > Use Incremental Source Framework in Flink CDC OceanBase Source

[jira] [Updated] (FLINK-34853) [Feature] submit Flink CDC pipeline job to k8s cluster.

[ https://issues.apache.org/jira/browse/FLINK-34853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34853: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > [Feature] submit Flink CDC

[jira] [Updated] (FLINK-34737) "Deployment - Kubernetes" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34737: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Deployment - Kubernetes"

[jira] [Updated] (FLINK-34738) "Deployment - YARN" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34738: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Deployment - YARN" Page

[jira] [Updated] (FLINK-34638) Support default value of table column.

[ https://issues.apache.org/jira/browse/FLINK-34638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34638: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Support default value of

[jira] [Resolved] (FLINK-34614) Add e2e test for Flink CDC pipeline job.

[ https://issues.apache.org/jira/browse/FLINK-34614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34614. --- Assignee: LvYanquan Resolution: Fixed > Add e2e test for Flink CDC pipeline job. >

[jira] [Commented] (FLINK-34614) Add e2e test for Flink CDC pipeline job.

[ https://issues.apache.org/jira/browse/FLINK-34614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847138#comment-17847138 ] LvYanquan commented on FLINK-34614: --- done in pull-request

[jira] [Updated] (FLINK-34595) Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils

[ https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34595: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Fix

Re: [PR] [FLINK-35047][state] Shutdown StateExecutors when ForStKeyedStateBackend is disposed [flink]

ljz2051 commented on code in PR #24768: URL: https://github.com/apache/flink/pull/24768#discussion_r1604284072 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackend.java: ## @@ -147,15 +160,30 @@ public S

[PR] [hotfix] Fix compilation error due to constructor removal of MockSourceReader [flink-benchmarks]

Zakelly opened a new pull request, #89: URL: https://github.com/apache/flink-benchmarks/pull/89 Due to this commit in main repo https://github.com/apache/flink/commit/41391065e1bf1476040039077049fbb98bec457e , there is a compilation error. This PR change to use another constructor of

[jira] [Updated] (FLINK-35343) NullPointerException in SourceReaderBase

[ https://issues.apache.org/jira/browse/FLINK-35343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zyh updated FLINK-35343: Description: h2. operation I used flink batch to read data from Doris and write to Doris.  The flink job

[jira] [Commented] (FLINK-35356) Async reducing state

[ https://issues.apache.org/jira/browse/FLINK-35356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847126#comment-17847126 ] Zakelly Lan commented on FLINK-35356: - Merged into master via

[jira] [Resolved] (FLINK-35356) Async reducing state

[ https://issues.apache.org/jira/browse/FLINK-35356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-35356. - Resolution: Fixed > Async reducing state > > > Key:

Re: [PR] [FLINK-35356][State] State descriptor and implementation for async reducing state [flink]

Zakelly merged PR #24798: URL: https://github.com/apache/flink/pull/24798 -- 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:

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

hanyuzheng7 commented on PR #24365: URL: https://github.com/apache/flink/pull/24365#issuecomment-2116497109 @dawidwys So We can use splitByWholeSeparatorPreserveAllTokens when the delimiter is not empty. When the delimiter is empty, do we need to handle this situation specially? -- This

[jira] [Created] (FLINK-35385) upgrader flink dependency version to 1.19

Hongshun Wang created FLINK-35385: - Summary: upgrader flink dependency version to 1.19 Key: FLINK-35385 URL: https://issues.apache.org/jira/browse/FLINK-35385 Project: Flink Issue Type:

[jira] [Updated] (FLINK-35384) Expose TaskIOMetricGroup to custom Partitioner via init Context

[ https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-35384: --- Summary: Expose TaskIOMetricGroup to custom Partitioner via init Context (was: Expose

[jira] [Comment Edited] (FLINK-35384) Expose TaskIOMetricGroup to custom Partitioner

[ https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847116#comment-17847116 ] Steven Zhen Wu edited comment on FLINK-35384 at 5/17/24 12:06 AM: -- one

[jira] [Commented] (FLINK-35384) Expose TaskIOMetricGroup to custom Partitioner

[ https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847116#comment-17847116 ] Steven Zhen Wu commented on FLINK-35384: one potential risk of this type of API is that it is

Re: [PR] [FLINK-35378] [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction [flink]

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

[jira] [Updated] (FLINK-35378) [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunc

[ https://issues.apache.org/jira/browse/FLINK-35378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35378: --- Labels: pull-request-available (was: ) > [FLIP-453] Promote Unified Sink API V2 to Public

[PR] [FLINK-35378] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction [flink]

MartijnVisser opened a new pull request, #24805: URL: https://github.com/apache/flink/pull/24805 ## What is the purpose of the change Promote Unified Sink API V2 to Public and Deprecate SinkFunction ## Brief change log da30c2faaa487ca03304b90553326ab189fba699 Deprecate

[jira] [Updated] (FLINK-35384) Expose TaskIOMetricGroup to custom Partitioner

[ https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-35384: --- Summary: Expose TaskIOMetricGroup to custom Partitioner (was: Expose metrics group to

[jira] [Updated] (FLINK-35384) Expose metrics group to custom Partitioner

[ https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-35384: --- Description: I am trying to implement a custom range partitioner in the Flink Iceberg sink.

[jira] [Created] (FLINK-35384) Expose metrics group to custom Partitioner

Steven Zhen Wu created FLINK-35384: -- Summary: Expose metrics group to custom Partitioner Key: FLINK-35384 URL: https://issues.apache.org/jira/browse/FLINK-35384 Project: Flink Issue Type:

Re: [PR] [FLINK-35383][docs] Update compatibility matrix for 1.19 release [flink]

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

Re: [PR] [FLINK-35383][docs] Update compatibility matrix for 1.19 release [flink]

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

[jira] [Assigned] (FLINK-35383) Update compatibility matrix to include 1.19 release

[ https://issues.apache.org/jira/browse/FLINK-35383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-35383: --- Assignee: Aleksandr Pilipenko > Update compatibility matrix to include 1.19

[PR] [FLINK-35383][docs] Update compatibility matrix for 1.19 release [flink]

z3d1k opened a new pull request, #24804: URL: https://github.com/apache/flink/pull/24804 ## What is the purpose of the change This pull requests updates the snapshot compatibility matrix for release 1.19. ## Brief change log Update compatibility matrix to include Flink

[PR] [FLINK-35383][docs] Update compatibility matrix for 1.19 release [flink]

z3d1k opened a new pull request, #24803: URL: https://github.com/apache/flink/pull/24803 ## What is the purpose of the change This pull requests updates the snapshot compatibility matrix for release 1.19. ## Brief change log Update compatibility matrix to include Flink

[jira] [Updated] (FLINK-35383) Update compatibility matrix to include 1.19 release

[ https://issues.apache.org/jira/browse/FLINK-35383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35383: --- Labels: pull-request-available (was: ) > Update compatibility matrix to include 1.19

[jira] [Created] (FLINK-35383) Update compatibility matrix to include 1.19 release

Aleksandr Pilipenko created FLINK-35383: --- Summary: Update compatibility matrix to include 1.19 release Key: FLINK-35383 URL: https://issues.apache.org/jira/browse/FLINK-35383 Project: Flink

[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847032#comment-17847032 ] Feng Jin commented on FLINK-35342: -- [~rskraba] Thank you for the reminder. I will run repeated tests on

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

MartijnVisser commented on PR #24365: URL: https://github.com/apache/flink/pull/24365#issuecomment-2115689935 > To confirm, you suggest to support an empty delimiter and in that case split all characters Yes -- This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-25168) Azure failed due to unable to transfer maven artifacts

[ https://issues.apache.org/jira/browse/FLINK-25168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847027#comment-17847027 ] Ryan Skraba commented on FLINK-25168: - * 1.19 cron_snapshot_deployment_maven

[jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847026#comment-17847026 ] Ryan Skraba commented on FLINK-26644: - * 1.19 Java 8 / Test (module: python)

[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847025#comment-17847025 ] Ryan Skraba commented on FLINK-35342: - I'm not entirely sure how this can be reproduced locally, but

[jira] [Commented] (FLINK-35380) ResumeCheckpointManuallyITCase hanging on tests

[ https://issues.apache.org/jira/browse/FLINK-35380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847022#comment-17847022 ] Ryan Skraba commented on FLINK-35380: - * 1.20 Default (Java 8) / Test (module: tests)

[jira] [Commented] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE

[ https://issues.apache.org/jira/browse/FLINK-35382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847020#comment-17847020 ] Ryan Skraba commented on FLINK-35382: - [~lijinzhong] Do you think this is related to the changes

[jira] [Created] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE

Ryan Skraba created FLINK-35382: --- Summary: ChangelogCompatibilityITCase.testRestore fails with an NPE Key: FLINK-35382 URL: https://issues.apache.org/jira/browse/FLINK-35382 Project: Flink

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

hanyuzheng7 commented on code in PR #24365: URL: https://github.com/apache/flink/pull/24365#discussion_r1603638142 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java: ## @@ -1721,4 +1722,83 @@ private Stream

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

hanyuzheng7 commented on PR #24365: URL: https://github.com/apache/flink/pull/24365#issuecomment-2115611425 > @MartijnVisser To confirm, you suggest to support an empty delimiter and in that case split all characters, meaning: > > ``` > SPLIT('abcde', '') = ['a', 'b', 'c', 'd',

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

hanyuzheng7 commented on code in PR #24365: URL: https://github.com/apache/flink/pull/24365#discussion_r1603638142 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java: ## @@ -1721,4 +1722,83 @@ private Stream

Re: [PR] [FLINK-20539][table-planner] Fix type mismatch when using ROW in comp… [flink]

snuyanzin commented on PR #23772: URL: https://github.com/apache/flink/pull/23772#issuecomment-2115525355 @xuyangzhong could you please rebase it to be sure it still passes the ci? Once it passes we could merge it -- This is an automated message from the Apache Git Service. To respond

[jira] [Assigned] (FLINK-35331) Download links for binary releases are displayed as source releases on website

[ https://issues.apache.org/jira/browse/FLINK-35331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-35331: --- Assignee: Hector Sanchez > Download links for binary releases are displayed as source releases on

[jira] [Created] (FLINK-35381) LocalRecoveryITCase failure on deleting directory

Ryan Skraba created FLINK-35381: --- Summary: LocalRecoveryITCase failure on deleting directory Key: FLINK-35381 URL: https://issues.apache.org/jira/browse/FLINK-35381 Project: Flink Issue Type:

[jira] [Commented] (FLINK-35358) Breaking change when loading artifacts

[ https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846991#comment-17846991 ] Ferenc Csaky commented on FLINK-35358: -- In that test class all directories are generated before

[jira] [Created] (FLINK-35380) ResumeCheckpointManuallyITCase hanging on tests

Ryan Skraba created FLINK-35380: --- Summary: ResumeCheckpointManuallyITCase hanging on tests Key: FLINK-35380 URL: https://issues.apache.org/jira/browse/FLINK-35380 Project: Flink Issue Type:

[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=17846975#comment-17846975 ] Lorenzo Affetti commented on FLINK-20628: - Sure thing, thank you [~chalixar] ! > Port RabbitMQ

[jira] [Comment Edited] (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=17846971#comment-17846971 ] Ahmed Hamdy edited comment on FLINK-20628 at 5/16/24 2:25 PM: --

[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=17846971#comment-17846971 ] Ahmed Hamdy commented on FLINK-20628: - [~affo] could you help with this one if you have capacity?

[jira] [Comment Edited] (FLINK-20539) Type mismatch when using ROW in computed column

[ https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846968#comment-17846968 ] Martijn Visser edited comment on FLINK-20539 at 5/16/24 2:17 PM: -

[jira] [Updated] (FLINK-28220) Create Table Like support excluding physical columns

[ https://issues.apache.org/jira/browse/FLINK-28220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28220: --- Fix Version/s: (was: 1.19.0) (was: 1.18.2) > Create Table Like

[jira] [Updated] (FLINK-20539) Type mismatch when using ROW in computed column

[ https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-20539: --- Fix Version/s: 1.18.2 1.19.0 > Type mismatch when using ROW in computed

[jira] [Updated] (FLINK-28220) Create Table Like support excluding physical columns

[ https://issues.apache.org/jira/browse/FLINK-28220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28220: --- Fix Version/s: 1.18.2 1.19.0 > Create Table Like support excluding

[jira] [Commented] (FLINK-20539) Type mismatch when using ROW in computed column

[ https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846968#comment-17846968 ] Martijn Visser commented on FLINK-20539: [~qingyue] Should this ticket have been closed already?

  1   2   3   >