Re: [PR] [FLINK-35068][core][type] Introduce built-in serialization support for java.util.Set [flink]

2024-05-27 Thread via GitHub
X-czh commented on PR #24845: URL: https://github.com/apache/flink/pull/24845#issuecomment-2134366106 @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] [Created] (FLINK-35469) Unstable test case 'testProject' of JdbcDynamicTableSourceITCase

2024-05-27 Thread RocMarshal (Jira)
RocMarshal created FLINK-35469: -- Summary: Unstable test case 'testProject' of JdbcDynamicTableSourceITCase Key: FLINK-35469 URL: https://issues.apache.org/jira/browse/FLINK-35469 Project: Flink

Re: [PR] [FLINK-33607][build]: Add checksum verification for Maven wrapper [flink]

2024-05-27 Thread via GitHub
flinkbot commented on PR #24852: URL: https://github.com/apache/flink/pull/24852#issuecomment-2134328506 ## CI report: * 35c1fce18fa24f0232edb86eee232482804795d2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-33607) Add checksum verification for Maven wrapper as well

2024-05-27 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849874#comment-17849874 ] Luke Chen commented on FLINK-33607: --- [~mapohl] , I've opened a PR to improve it. Please help assign

[jira] [Commented] (FLINK-33607) Add checksum verification for Maven wrapper as well

2024-05-27 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849873#comment-17849873 ] Luke Chen commented on FLINK-33607: --- PR: [https://github.com/apache/flink/pull/24852] After

[jira] [Updated] (FLINK-33607) Add checksum verification for Maven wrapper as well

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33607: --- Labels: pull-request-available (was: ) > Add checksum verification for Maven wrapper as

[PR] FLINK-33607: Add checksum verification for Maven wrapper [flink]

2024-05-27 Thread via GitHub
showuon opened a new pull request, #24852: URL: https://github.com/apache/flink/pull/24852 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Updated] (FLINK-35468) [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35468: --- Labels: pull-request-available (was: ) > [Connectors/Pulsar] update

Re: [PR] [FLINK-35468][Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment [flink-connector-pulsar]

2024-05-27 Thread via GitHub
boring-cyborg[bot] commented on PR #93: URL: https://github.com/apache/flink-connector-pulsar/pull/93#issuecomment-2134308720 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[PR] [FLINK-35468][Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment [flink-connector-pulsar]

2024-05-27 Thread via GitHub
geniusjoe opened a new pull request, #93: URL: https://github.com/apache/flink-connector-pulsar/pull/93 ## Purpose of the change Since we [deleted shared and key-shared subscription type](https://issues.apache.org/jira/browse/FLINK-30413) in pulsar source connector, I

[jira] [Created] (FLINK-35468) [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment

2024-05-27 Thread zhou zhuohan (Jira)
zhou zhuohan created FLINK-35468: Summary: [Connectors/Pulsar] update isEnableAutoAcknowledgeMessage config comment Key: FLINK-35468 URL: https://issues.apache.org/jira/browse/FLINK-35468 Project:

[jira] [Comment Edited] (FLINK-35438) SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error

2024-05-27 Thread Rob Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849850#comment-17849850 ] Rob Young edited comment on FLINK-35438 at 5/28/24 3:45 AM: I agree there's

Re: [PR] [FLINK-35432]Support catch modify event for the mysql. [flink-cdc]

2024-05-27 Thread via GitHub
yuxiqian commented on PR #3352: URL: https://github.com/apache/flink-cdc/pull/3352#issuecomment-2134293705 > @yuxiqian can you help me trigger cicd? Sorry I do not have such privilege, either. You may create a PR to your fork repository (e.g. from `hk-lrzy:FLINK-35432` to

Re: [PR] [hotfix] Fix incompatible type of JobManagerOptions.SLOT_REQUEST_OUT value [flink]

2024-05-27 Thread via GitHub
X-czh closed pull request #24851: [hotfix] Fix incompatible type of JobManagerOptions.SLOT_REQUEST_OUT value URL: https://github.com/apache/flink/pull/24851 -- 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] [hotfix] Fix incompatible type of JobManagerOptions.SLOT_REQUEST_OUT value [flink]

2024-05-27 Thread via GitHub
JunRuiLee commented on PR #24851: URL: https://github.com/apache/flink/pull/24851#issuecomment-2134282190 @X-czh Thank you very much for the reminder. Another fix has been merged (https://github.com/apache/flink/pull/24850), you can try to rebase onto master. -- This is an automated

Re: [PR] [FLINK-35432]Support catch modify event for the mysql. [flink-cdc]

2024-05-27 Thread via GitHub
hk-lrzy commented on PR #3352: URL: https://github.com/apache/flink-cdc/pull/3352#issuecomment-2134282172 @yuxiqian can you help me trigger cicd? -- 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] [hotfix] Fix incompatible type of JobManagerOptions.SLOT_REQUEST_OUT value [flink]

2024-05-27 Thread via GitHub
flinkbot commented on PR #24851: URL: https://github.com/apache/flink/pull/24851#issuecomment-2134281847 ## CI report: * e672a30887809c13a14c4103076f560ebbcee092 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [hotfix] Fix incompatible type of JobManagerOptions.SLOT_REQUEST_OUT value [flink]

2024-05-27 Thread via GitHub
X-czh commented on PR #24851: URL: https://github.com/apache/flink/pull/24851#issuecomment-2134279139 @JunRuiLee Hi, a recent change (FLINK-35359) changes the type of JobManagerOptions.SLOT_REQUEST_OUT to Duration, which conflicts with your recent change in FLINK-35465, leading to

[PR] [hotfix] Fix incompatible type of JobManagerOptions.SLOT_REQUEST_OUT value [flink]

2024-05-27 Thread via GitHub
X-czh opened a new pull request, #24851: URL: https://github.com/apache/flink/pull/24851 ## What is the purpose of the change Fix incompatible type of JobManagerOptions.SLOT_REQUEST_OUT value. ## Verifying this change This change is a trivial rework / code

Re: [PR] [FLINK-35425][table-common] Support convert freshness to cron expression in full refresh mode [flink]

2024-05-27 Thread via GitHub
lsyldliu commented on code in PR #24849: URL: https://github.com/apache/flink/pull/24849#discussion_r1616527538 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/IntervalFreshness.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35425][table-common] Support convert freshness to cron expression in full refresh mode [flink]

2024-05-27 Thread via GitHub
lsyldliu commented on code in PR #24849: URL: https://github.com/apache/flink/pull/24849#discussion_r1616527538 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/IntervalFreshness.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software

Re: [PR] [hotfix] Fix modification conflict between FLINK-35465 and FLINK-35359 [flink]

2024-05-27 Thread via GitHub
zhuzhurk commented on PR #24850: URL: https://github.com/apache/flink/pull/24850#issuecomment-2134275369 The change is trivial. Will merge it right now to unblock others. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Resolved] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE

2024-05-27 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35457. Resolution: Fixed > EventTimeWindowCheckpointingITCase fails on AZP as NPE >

Re: [PR] [hotfix] Fix modification conflict between FLINK-35465 and FLINK-35359 [flink]

2024-05-27 Thread via GitHub
zhuzhurk merged PR #24850: URL: https://github.com/apache/flink/pull/24850 -- 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] [Assigned] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE

2024-05-27 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35457: -- Assignee: Yanfei Lei > EventTimeWindowCheckpointingITCase fails on AZP as NPE >

[jira] [Commented] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE

2024-05-27 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849864#comment-17849864 ] Yanfei Lei commented on FLINK-35457: Merged into master via 1e996b8 >

Re: [PR] [FLINK-35425][table-common] Support convert freshness to cron expression in full refresh mode [flink]

2024-05-27 Thread via GitHub
lsyldliu commented on code in PR #24849: URL: https://github.com/apache/flink/pull/24849#discussion_r1616524117 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/IntervalFreshness.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35457][checkpoint] Hotfix! close physical file under the protection of lock [flink]

2024-05-27 Thread via GitHub
fredia merged PR #24846: URL: https://github.com/apache/flink/pull/24846 -- 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] [hotfix] Fix modification conflict between FLINK-35465 and FLINK-35359 [flink]

2024-05-27 Thread via GitHub
flinkbot commented on PR #24850: URL: https://github.com/apache/flink/pull/24850#issuecomment-2134269337 ## CI report: * 90c1170d07dea3e1373a34fe245e4ec7ccdab592 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-35447) Flink CDC Document document file had removed but website can access

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849862#comment-17849862 ] Leonard Xu edited comment on FLINK-35447 at 5/28/24 2:58 AM: - master:

[jira] [Resolved] (FLINK-35447) Flink CDC Document document file had removed but website can access

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35447. Resolution: Implemented > Flink CDC Document document file had removed but website can access >

Re: [PR] [BP-3.1][FLINK-35447][doc-ci] Flink CDC Document document file had removed but website can access [flink-cdc]

2024-05-27 Thread via GitHub
leonardBang merged PR #3367: URL: https://github.com/apache/flink-cdc/pull/3367 -- 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] [BP-3.0][FLINK-35447][doc-ci] Flink CDC Document document file had removed but website can access [flink-cdc]

2024-05-27 Thread via GitHub
leonardBang merged PR #3368: URL: https://github.com/apache/flink-cdc/pull/3368 -- 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] [Commented] (FLINK-35447) Flink CDC Document document file had removed but website can access

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849862#comment-17849862 ] Leonard Xu commented on FLINK-35447: master: d97124fb9f531193d8b232862af44e6bcca03277 > Flink CDC

[jira] [Updated] (FLINK-35447) Flink CDC Document document file had removed but website can access

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35447: --- Fix Version/s: cdc-3.2.0 cdc-3.1.1 > Flink CDC Document document file had

[jira] [Updated] (FLINK-35447) Flink CDC Document document file had removed but website can access

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35447: --- Affects Version/s: cdc-3.1.0 > Flink CDC Document document file had removed but website can access

Re: [PR] [FLINK-35348][table] Introduce refresh materialized table rest api [flink]

2024-05-27 Thread via GitHub
hackergin commented on code in PR #24844: URL: https://github.com/apache/flink/pull/24844#discussion_r1616519135 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpointMaterializedTableITCase.java: ## @@ -0,0 +1,129 @@ +/* + *

[jira] [Assigned] (FLINK-35447) Flink CDC Document document file had removed but website can access

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35447: -- Assignee: Zhongqiang Gong > Flink CDC Document document file had removed but website can

Re: [PR] [FLINK-35447][doc-ci] Flink CDC Document document file had removed but website can access [flink-cdc]

2024-05-27 Thread via GitHub
leonardBang merged PR #3362: URL: https://github.com/apache/flink-cdc/pull/3362 -- 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] [hotfix] Fix modification conflict between FLINK-35465 and FLINK-35359 [flink]

2024-05-27 Thread via GitHub
zoltar9264 opened a new pull request, #24850: URL: https://github.com/apache/flink/pull/24850 ## What is the purpose of the change As title said, fix the compile error cause by modification conflict between FLINK-35465 and FLINK-35359. ## Verifying this change This

Re: [PR] [FLINK-35348][table] Introduce refresh materialized table rest api [flink]

2024-05-27 Thread via GitHub
hackergin commented on code in PR #24844: URL: https://github.com/apache/flink/pull/24844#discussion_r1616517183 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/MaterializedTableStatementITCase.java: ## @@ -909,47 +694,172 @@ void

Re: [PR] [FLINK-35129][cdc][postgres] Add checkpoint cycle option for commit offsets [flink-cdc]

2024-05-27 Thread via GitHub
loserwang1024 commented on PR #3349: URL: https://github.com/apache/flink-cdc/pull/3349#issuecomment-2134261272 LGTM! @leonardBang @ruanhang1993 , CC, WDYT of the option name `checkpoint.cycle` -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] [FLINK-35425][table-common] Support convert freshness to cron expression in full refresh mode [flink]

2024-05-27 Thread via GitHub
hackergin commented on code in PR #24849: URL: https://github.com/apache/flink/pull/24849#discussion_r161654 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/IntervalFreshness.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache Software

[jira] [Comment Edited] (FLINK-35360) [Feature] Submit Flink CDC pipeline job yarn Application mode

2024-05-27 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849856#comment-17849856 ] wangjunbo edited comment on FLINK-35360 at 5/28/24 2:38 AM: discuss in 

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

2024-05-27 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849860#comment-17849860 ] wangjunbo edited comment on FLINK-34904 at 5/28/24 2:37 AM: [~czy006]

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

2024-05-27 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849860#comment-17849860 ] wangjunbo edited comment on FLINK-34904 at 5/28/24 2:36 AM: [~czy006]

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

2024-05-27 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849860#comment-17849860 ] wangjunbo edited comment on FLINK-34904 at 5/28/24 2:35 AM: [~czy006]

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

2024-05-27 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849860#comment-17849860 ] wangjunbo commented on FLINK-34904: --- [~czy006] Looking forward to the realization of

Re: [PR] [FLINK-35457][checkpoint] Hotfix! close physical file under the protection of lock [flink]

2024-05-27 Thread via GitHub
fredia commented on code in PR #24846: URL: https://github.com/apache/flink/pull/24846#discussion_r1616500402 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java: ## @@ -131,19 +131,22 @@ public abstract class

Re: [PR] [FLINK-34456][configuration]Move all checkpoint-related options into CheckpointingOptions [flink]

2024-05-27 Thread via GitHub
spoon-lz commented on PR #24374: URL: https://github.com/apache/flink/pull/24374#issuecomment-2134232797 @Zakelly @masteryhx Sorry I made the mistake of committing to the wrong branch, the code has been updated. -- This is an automated message from the Apache Git Service. To respond to

[jira] [Comment Edited] (FLINK-35360) [Feature] Submit Flink CDC pipeline job yarn Application mode

2024-05-27 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849856#comment-17849856 ] wangjunbo edited comment on FLINK-35360 at 5/28/24 2:04 AM: discuss in 

Re: [PR] [FLINK-35360] Submit Flink CDC pipeline job yarn Application mode [flink-cdc]

2024-05-27 Thread via GitHub
beryllw commented on PR #3366: URL: https://github.com/apache/flink-cdc/pull/3366#issuecomment-2134231318 k8s application mode pr: https://github.com/apache/flink-cdc/pull/3093/files -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-35360) [Feature] Submit Flink CDC pipeline job yarn Application mode

2024-05-27 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849856#comment-17849856 ] wangjunbo commented on FLINK-35360: --- discuss in FLINK-34853 and FLINK-34904 > [Feature] Submit Flink

[jira] [Resolved] (FLINK-35460) Check file size when position read for ForSt

2024-05-27 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-35460. -- Fix Version/s: 1.20.0 Resolution: Fixed Merged 9fbe9f30 into master. > Check file

Re: [PR] [FLINK-35460][state] Adjust read size when ByteBuffer size is larger than file size for ForSt [flink]

2024-05-27 Thread via GitHub
masteryhx closed pull request #24847: [FLINK-35460][state] Adjust read size when ByteBuffer size is larger than file size for ForSt URL: https://github.com/apache/flink/pull/24847 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-35121) CDC pipeline connector should verify requiredOptions and optionalOptions

2024-05-27 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849854#comment-17849854 ] wangjunbo commented on FLINK-35121: --- [~loserwang1024] I'm willing to take this. > CDC pipeline

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

2024-05-27 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849852#comment-17849852 ] wangjunbo edited comment on FLINK-34595 at 5/28/24 1:54 AM: [~kunni] Looks

[jira] [Closed] (FLINK-35465) Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures.

2024-05-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-35465. --- Resolution: Done master: b8173eb662ee5823de40de356869d0064de2c22a 3206659db5b7c4ce645072f11f091e0e9e92b0ce

[jira] [Updated] (FLINK-35465) Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures.

2024-05-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-35465: Fix Version/s: 1.20.0 > Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster >

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

2024-05-27 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849852#comment-17849852 ] wangjunbo commented on FLINK-34595: --- Looks like closed by

[jira] [Updated] (FLINK-35465) Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures.

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35465: --- Labels: pull-request-available (was: ) > Introduce BatchJobRecoveryHandler for recovery of

Re: [PR] [FLINK-35465][runtime] Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures. [flink]

2024-05-27 Thread via GitHub
zhuzhurk merged PR #24771: URL: https://github.com/apache/flink/pull/24771 -- 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] [Assigned] (FLINK-35465) Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures.

2024-05-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-35465: --- Assignee: Junrui Li > Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster

Re: [PR] [FLINK-35448] Translate pod templates documentation into Chinese [flink-kubernetes-operator]

2024-05-27 Thread via GitHub
RocMarshal commented on code in PR #830: URL: https://github.com/apache/flink-kubernetes-operator/pull/830#discussion_r1616483112 ## docs/content/docs/custom-resource/pod-template.md: ## @@ -93,16 +90,18 @@ spec: ``` {{< hint info >}} -When using the operator with Flink

Re: [PR] [FLINK-35448] Translate pod templates documentation into Chinese [flink-kubernetes-operator]

2024-05-27 Thread via GitHub
RocMarshal commented on code in PR #830: URL: https://github.com/apache/flink-kubernetes-operator/pull/830#discussion_r1616482602 ## docs/content/docs/custom-resource/pod-template.md: ## @@ -26,21 +26,18 @@ under the License. # Pod template -The operator CRD is designed

[jira] [Updated] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35464: --- Labels: pull-request-available (was: ) > Flink CDC 3.1 breaks operator state compatiblity

Re: [PR] [FLINK-35068][core][type] Introduce built-in serialization support for java.util.Set [flink]

2024-05-27 Thread via GitHub
X-czh commented on PR #24845: URL: https://github.com/apache/flink/pull/24845#issuecomment-2134201750 @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.

[PR] [FLINK-35464] Fixes operator state backwards compatibility from CDC 3.0.x [flink-cdc]

2024-05-27 Thread via GitHub
yuxiqian opened a new pull request, #3369: URL: https://github.com/apache/flink-cdc/pull/3369 This closes FLINK-35441 and FLINK-35464. Flink CDC 3.1 changes how SchemaRegistry [de]serializes state data, which causes any checkpoint states saved with earlier version could not be

[jira] [Commented] (FLINK-35438) SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error

2024-05-27 Thread Rob Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849850#comment-17849850 ] Rob Young commented on FLINK-35438: --- I agree there's a race that's hard to reproduce, I can only

[jira] [Created] (FLINK-35467) The flink-cdc.sh script of flink-cdc-3.1.0 cannot read the correct Flink configuration information specified by the flink-conf.yaml through the FLINK_CONF_DIR environmen

2024-05-27 Thread Justin.Liu (Jira)
Justin.Liu created FLINK-35467: -- Summary: The flink-cdc.sh script of flink-cdc-3.1.0 cannot read the correct Flink configuration information specified by the flink-conf.yaml through the FLINK_CONF_DIR environment variable. Key:

[jira] [Commented] (FLINK-35418) EventTimeWindowCheckpointingITCase fails with an NPE

2024-05-27 Thread Rob Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849841#comment-17849841 ] Rob Young commented on FLINK-35418: --- looks like the same issue as

[jira] [Resolved] (FLINK-33759) flink parquet writer support write nested array or map type

2024-05-27 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33759. - Fix Version/s: 1.20.0 Resolution: Fixed > flink parquet writer support write nested array or map

[jira] [Updated] (FLINK-33759) flink parquet writer support write nested array or map type

2024-05-27 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33759: Affects Version/s: 1.19.0 > flink parquet writer support write nested array or map type >

[jira] [Commented] (FLINK-33759) flink parquet writer support write nested array or map type

2024-05-27 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849837#comment-17849837 ] Jing Ge commented on FLINK-33759: - master:

Re: [PR] [FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type [flink]

2024-05-27 Thread via GitHub
JingGe merged PR #24795: URL: https://github.com/apache/flink/pull/24795 -- 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] Enable async profiler [flink-benchmarks]

2024-05-27 Thread via GitHub
SamBarker commented on PR #90: URL: https://github.com/apache/flink-benchmarks/pull/90#issuecomment-2134019437 > AFAIU, by default profiling is not turned on. One has to activate enable-async-profiler profile? Yes that's almost right. The profile is enabled automatically by

Re: [PR] Enable async profiler [flink-benchmarks]

2024-05-27 Thread via GitHub
SamBarker commented on code in PR #90: URL: https://github.com/apache/flink-benchmarks/pull/90#discussion_r1616369948 ## pom.xml: ## @@ -290,25 +291,31 @@ under the License.

Re: [PR] [FLINK-35348][table] Introduce refresh materialized table rest api [flink]

2024-05-27 Thread via GitHub
hackergin commented on code in PR #24844: URL: https://github.com/apache/flink/pull/24844#discussion_r1616305580 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/MaterializedTableStatementITCase.java: ## @@ -909,47 +694,172 @@ void

Re: [PR] [FLINK-35348][table] Introduce refresh materialized table rest api [flink]

2024-05-27 Thread via GitHub
hackergin commented on code in PR #24844: URL: https://github.com/apache/flink/pull/24844#discussion_r1616304880 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpointMaterializedTableITCase.java: ## @@ -0,0 +1,129 @@ +/* + *

Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]

2024-05-27 Thread via GitHub
XComp commented on code in PR #24426: URL: https://github.com/apache/flink/pull/24426#discussion_r1616244045 ## .github/workflows/nightly.yml: ## @@ -94,3 +94,46 @@ jobs: s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }} s3_access_key: ${{ secrets.IT_CASE_S3_ACCESS_KEY

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

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

Re: [PR] Enable async profiler [flink-benchmarks]

2024-05-27 Thread via GitHub
pnowojski commented on code in PR #90: URL: https://github.com/apache/flink-benchmarks/pull/90#discussion_r1616223910 ## benchmark.sh: ## @@ -0,0 +1,54 @@ +#!/usr/bin/env bash Review Comment: I would mark this as executable. ## benchmark.sh: ## @@ -0,0

Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]

2024-05-27 Thread via GitHub
morazow commented on code in PR #24426: URL: https://github.com/apache/flink/pull/24426#discussion_r1616229933 ## .github/workflows/nightly.yml: ## @@ -94,3 +94,46 @@ jobs: s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }} s3_access_key: ${{

[jira] [Commented] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849767#comment-17849767 ] Ryan Skraba commented on FLINK-35446: - Thanks for the fix! There were a bunch of failures over the

Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow [flink]

2024-05-27 Thread via GitHub
XComp commented on code in PR #24426: URL: https://github.com/apache/flink/pull/24426#discussion_r1616177599 ## .github/workflows/nightly.yml: ## @@ -94,3 +94,46 @@ jobs: s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }} s3_access_key: ${{ secrets.IT_CASE_S3_ACCESS_KEY

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

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849765#comment-17849765 ] Ryan Skraba commented on FLINK-35380: - * 1.20 Java 21 / Test (module: tests)

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849759#comment-17849759 ] Ryan Skraba commented on FLINK-28440: - * 1.19 Java 21 / Test (module: tests)

[jira] [Commented] (FLINK-35002) GitHub action request timeout to ArtifactService

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849763#comment-17849763 ] Ryan Skraba commented on FLINK-35002: - * 1.20 Java 11 / Compile

[jira] [Commented] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849764#comment-17849764 ] Ryan Skraba commented on FLINK-35012: - * 1.20 AdaptiveScheduler / Test (module: table)

[jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849760#comment-17849760 ] Ryan Skraba commented on FLINK-34224: - * 1.20 Hadoop 3.1.3 / Test (module: core)

[jira] [Commented] (FLINK-34645) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849762#comment-17849762 ] Ryan Skraba commented on FLINK-34645: - * 1.18 Hadoop 3.1.3 / Test (module: misc)

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849761#comment-17849761 ] Ryan Skraba commented on FLINK-34227: - * 1.18 AdaptiveScheduler / Test (module: table)

[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849758#comment-17849758 ] Ryan Skraba commented on FLINK-18476: - * 1.20 Java 21 / Test (module: misc)

Re: [PR] [doc]Flink sql gettingstarted Expression 'dept_id' is not being grouped [flink]

2024-05-27 Thread via GitHub
ZmmBigdata commented on PR #24841: URL: https://github.com/apache/flink/pull/24841#issuecomment-2133532442 Two more files have been committed docs:flink-docs-release-1.19/docs/dev/table/sql/queries/overview/ [docs]Flink sql queries-overview Missing required options are:path

[jira] [Commented] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError

2024-05-27 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849740#comment-17849740 ] Jing Ge commented on FLINK-34379: - master: 87b7193846090897b2feabf716ee5378bcd7585b >

Re: [PR] [FLINK-34379][table] Fix adding catalogtable logic [flink]

2024-05-27 Thread via GitHub
JingGe merged PR #24788: URL: https://github.com/apache/flink/pull/24788 -- 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-35412][State/Runtime] Batch execution of async state request callback [flink]

2024-05-27 Thread via GitHub
jectpro7 commented on code in PR #24832: URL: https://github.com/apache/flink/pull/24832#discussion_r1616029786 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/BatchCallbackRunner.java: ## @@ -0,0 +1,117 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-34379][table] Fix adding catalogtable logic [flink]

2024-05-27 Thread via GitHub
JingGe commented on code in PR #24788: URL: https://github.com/apache/flink/pull/24788#discussion_r1611948679 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -234,20 +234,16 @@ private static boolean

Re: [PR] [FLINK-35049][state] Implement Map Async State API for ForStStateBackend [flink]

2024-05-27 Thread via GitHub
masteryhx commented on code in PR #24812: URL: https://github.com/apache/flink/pull/24812#discussion_r1616045622 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStIterateOperation.java: ## @@ -0,0 +1,226 @@ +/* + * Licensed to the

Re: [PR] [FLINK-35425][table-common] Support convert freshness to cron expression in full refresh mode [flink]

2024-05-27 Thread via GitHub
flinkbot commented on PR #24849: URL: https://github.com/apache/flink/pull/24849#issuecomment-2133449299 ## CI report: * 0bd839dee3158adc10d417d271a13f4aa14669e7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

  1   2   3   >