[PR] [hotfix] Optimize SchemaChangeEventVisitor: use generic visitor handler class & introduce voidVisitors [flink-cdc]

2024-10-11 Thread via GitHub
yuxiqian opened a new pull request, #3638: URL: https://github.com/apache/flink-cdc/pull/3638 This PR cleans up `SchemaChangeEventVisitor` class by: * Using templated `VisitorHandler` to replace individual `XXXEventVisitor` classes * Introduce `voidVisit` method for visitors that d

Re: [PR] [FLINK-36513][ci] Introducing retry mechanism for `kubectl apply cert-manager` [flink-kubernetes-operator]

2024-10-11 Thread via GitHub
gyfora commented on PR #897: URL: https://github.com/apache/flink-kubernetes-operator/pull/897#issuecomment-2408425091 I generally would prefer storing the yaml in our code base if that’s possible to avoid this but if you like this approach more then good to go from my end :) -- This is

Re: [PR] Add release announcement for Flink 2.0 Preview. [flink-web]

2024-10-11 Thread via GitHub
Sxnan commented on PR #754: URL: https://github.com/apache/flink-web/pull/754#issuecomment-2408417821 > Furthermore, there’s another type of change regarding SQL Client startup options, how about adding a category like: > > List of SQL Client startup options changes > > The fol

Re: [PR] [tests][ci] Refactor ci [flink-cdc]

2024-10-11 Thread via GitHub
Jiabao-Sun commented on PR #3626: URL: https://github.com/apache/flink-cdc/pull/3626#issuecomment-2408412857 Thanks @GOODBOY008 for this great work. How about using github action's matrix to control flink's version that can improve the coverage of the flink versions and simplify the Param

Re: [PR] Add release announcement for Flink 2.0 Preview. [flink-web]

2024-10-11 Thread via GitHub
Sxnan commented on code in PR #754: URL: https://github.com/apache/flink-web/pull/754#discussion_r1797606978 ## docs/content/posts/2024-10-01-release-2.0-preview.md: ## @@ -0,0 +1,1264 @@ +--- +authors: +- xtsong: + name: "Xintong Song" +date: "2024-10-01T08:00:00Z" +subtitle:

Re: [PR] Add release announcement for Flink 2.0 Preview. [flink-web]

2024-10-11 Thread via GitHub
Sxnan commented on code in PR #754: URL: https://github.com/apache/flink-web/pull/754#discussion_r1797606854 ## docs/content/posts/2024-10-01-release-2.0-preview.md: ## @@ -0,0 +1,1264 @@ +--- +authors: +- xtsong: + name: "Xintong Song" +date: "2024-10-01T08:00:00Z" +subtitle:

Re: [PR] Add release announcement for Flink 2.0 Preview. [flink-web]

2024-10-11 Thread via GitHub
Sxnan commented on code in PR #754: URL: https://github.com/apache/flink-web/pull/754#discussion_r1797603838 ## docs/content/posts/2024-10-01-release-2.0-preview.md: ## @@ -0,0 +1,1264 @@ +--- +authors: +- xtsong: + name: "Xintong Song" +date: "2024-10-01T08:00:00Z" +subtitle:

[jira] [Resolved] (FLINK-35156) Wire new operators for async state with DataStream V2

2024-10-11 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35156. Resolution: Resolved > Wire new operators for async state with DataStream V2 > ---

Re: [PR] [FLINK-35029][state/forst] Store timer in JVM heap when use async state backend [flink]

2024-10-11 Thread via GitHub
flinkbot commented on PR #25501: URL: https://github.com/apache/flink/pull/25501#issuecomment-2408387232 ## CI report: * f8aef7729f7a9e19d709f502b22a0dbee1815a3c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35029) Store timer in JVM heap when async execution enabled

2024-10-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35029: --- Labels: pull-request-available (was: ) > Store timer in JVM heap when async execution enabl

[PR] [FLINK-35029][state/forst] Store timer in JVM heap when use async state backend [flink]

2024-10-11 Thread via GitHub
fredia opened a new pull request, #25501: URL: https://github.com/apache/flink/pull/25501 ## What is the purpose of the change This PR supports storing timer in JVM heap when use async state backend. Note: Timers are stored as raw keyed state instead of managed keyed state

[jira] [Resolved] (FLINK-36448) Compilation fails in IntelliJ

2024-10-11 Thread Kumar Mallikarjuna (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kumar Mallikarjuna resolved FLINK-36448. Resolution: Resolved > Compilation fails in IntelliJ > ---

[jira] [Commented] (FLINK-36448) Compilation fails in IntelliJ

2024-10-11 Thread Kumar Mallikarjuna (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1717#comment-1717 ] Kumar Mallikarjuna commented on FLINK-36448: Hi [~yyhx] , [~wenjun] , [~xtso

Re: [PR] [FLINK-36452][mysql] Replace ArrayList with TreeSet to speed up searching of FinishedSnapshotSplitInfo for specific chunkKey. [flink-cdc]

2024-10-11 Thread via GitHub
hadoopkandy commented on PR #3630: URL: https://github.com/apache/flink-cdc/pull/3630#issuecomment-2408338673 method getExecutorService() is not found in binlogReader, method BinlogSplitReader#getExecutorService should commit -- This is an automated message from the Apache Git Ser

Re: [PR] [FLINK-36452][mysql] Replace ArrayList with TreeSet to speed up searching of FinishedSnapshotSplitInfo for specific chunkKey. [flink-cdc]

2024-10-11 Thread via GitHub
hadoopkandy commented on PR #3630: URL: https://github.com/apache/flink-cdc/pull/3630#issuecomment-2408337824 method getExecutorService() is not found in binlogReader, method BinlogSplitReader#getExecutorService should commit -- This is an automated message from the Apache Git Service. T

[jira] [Updated] (FLINK-36514) Unable to override include/exclude schema types in lenient mode

2024-10-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36514: --- Labels: pull-request-available (was: ) > Unable to override include/exclude schema types in

[jira] [Created] (FLINK-36515) Adds high-precision TIME type support in YAML pipeline

2024-10-11 Thread yux (Jira)
yux created FLINK-36515: --- Summary: Adds high-precision TIME type support in YAML pipeline Key: FLINK-36515 URL: https://issues.apache.org/jira/browse/FLINK-36515 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36514) Unable to override include/exclude schema types in lenient mode

2024-10-11 Thread yux (Jira)
yux created FLINK-36514: --- Summary: Unable to override include/exclude schema types in lenient mode Key: FLINK-36514 URL: https://issues.apache.org/jira/browse/FLINK-36514 Project: Flink Issue Type: Bu

Re: [PR] [FLINK-36474] Support merging timestamp columns when routing [flink-cdc]

2024-10-11 Thread via GitHub
aiwenmo commented on code in PR #3636: URL: https://github.com/apache/flink-cdc/pull/3636#discussion_r1797537900 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java: ## @@ -624,4 +672,21 @@ public void snapshotState(StateSnapshotC

[jira] [Updated] (FLINK-36469) Bump commons-io from 2.11.0 to 2.17.0

2024-10-11 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36469: Affects Version/s: kubernetes-operator-1.9.0 (was: kubernetes-operator-1.10.0)

[jira] [Resolved] (FLINK-36469) Bump commons-io from 2.11.0 to 2.17.0

2024-10-11 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-36469. - Fix Version/s: kubernetes-operator-1.10.0 Assignee: Siddharth R Resolution: Fixed Merged

Re: [PR] [FLINK-36469] Bump commons-io from 2.11.0 to 2.17.0 [flink-kubernetes-operator]

2024-10-11 Thread via GitHub
1996fanrui merged PR #894: URL: https://github.com/apache/flink-kubernetes-operator/pull/894 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsu

[jira] [Updated] (FLINK-36513) A lot of CI failures are caused by Install cert-manager

2024-10-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36513: --- Labels: pull-request-available (was: ) > A lot of CI failures are caused by Install cert-ma

[PR] [FLINK-36513][ci] Introducing retry mechanism for `kubectl apply cert-manager` [flink-kubernetes-operator]

2024-10-11 Thread via GitHub
1996fanrui opened a new pull request, #897: URL: https://github.com/apache/flink-kubernetes-operator/pull/897 ## What is the purpose of the change A lot of CI failures are caused by Install cert-manager. Get more details from FLINK-36513. ## Brief change log [FLINK-

[jira] [Updated] (FLINK-36513) A lot of CI failures are caused by Install cert-manager

2024-10-11 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36513: Description: A lot of CI failures are caused by Install cert-manager, such as: [https://github.com/apache

[jira] [Comment Edited] (FLINK-36446) Refactor Job Submission Process to Use ExecutionPlan Instead of JobGraph

2024-10-11 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1706#comment-1706 ] Junrui Li edited comment on FLINK-36446 at 10/12/24 2:49 AM: -

[jira] [Updated] (FLINK-36513) A lot of CI failures are caused by Install cert-manager

2024-10-11 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36513: Description: A lot of CI failures are caused by Install cert-manager, such as: [https://github.com/apache

[jira] [Updated] (FLINK-36513) A lot of CI failures are caused by Install cert-manager

2024-10-11 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36513: Description: A lot of CI failures are caused by Install cert-manager, such as: [https://github.com/apache

[jira] [Updated] (FLINK-36513) A lot of CI failures are caused by Install cert-manager

2024-10-11 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36513: Description: A lot of CI failures are caused by Install cert-manager, such as: [https://github.com/apache

[jira] [Created] (FLINK-36513) A lot of CI failures are caused by Install cert-manager

2024-10-11 Thread Rui Fan (Jira)
Rui Fan created FLINK-36513: --- Summary: A lot of CI failures are caused by Install cert-manager Key: FLINK-36513 URL: https://issues.apache.org/jira/browse/FLINK-36513 Project: Flink Issue Type: Tec

[jira] [Commented] (FLINK-36446) Refactor Job Submission Process to Use ExecutionPlan Instead of JobGraph

2024-10-11 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1706#comment-1706 ] Junrui Li commented on FLINK-36446: --- [~davidradl]  ExecutionPlan is a generic interfac

Re: [PR] Add release announcement for Flink 2.0 Preview. [flink-web]

2024-10-11 Thread via GitHub
zhuzhurk commented on code in PR #754: URL: https://github.com/apache/flink-web/pull/754#discussion_r1797534041 ## docs/content/posts/2024-10-01-release-2.0-preview.md: ## @@ -0,0 +1,1264 @@ +--- +authors: +- xtsong: + name: "Xintong Song" +date: "2024-10-01T08:00:00Z" +subtitl

[jira] [Closed] (FLINK-23620) Introduce proper YAML parsing to Flink's configuration

2024-10-11 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-23620. --- Fix Version/s: 2.0-preview (was: 2.0.0) Resolution: Done > Introduce proper YA

[jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1705#comment-1705 ] Weijie Guo commented on FLINK-36167: https://dev.azure.com/apache-flink/apache-flink

Re: [PR] [FLINK-36474] Support merging timestamp columns when routing [flink-cdc]

2024-10-11 Thread via GitHub
yuxiqian commented on code in PR #3636: URL: https://github.com/apache/flink-cdc/pull/3636#discussion_r1797533354 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java: ## @@ -609,6 +643,34 @@ public Object getFieldOrNull(RecordData

Re: [PR] [FLINK-32176] Exclude snakeyaml from pulsar-client-all to mitigate CVE-2022-1471 [flink-connector-pulsar]

2024-10-11 Thread via GitHub
syhily commented on PR #51: URL: https://github.com/apache/flink-connector-pulsar/pull/51#issuecomment-2408311791 We are planning to use the LTS version of the Pulsar client. But the ci can't be passed cause some strange test issues -- This is an automated message from the Apache Git Ser

[jira] [Updated] (FLINK-35580) Improvements and fix ingestDB recovery mode related bugs

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35580: --- Fix Version/s: 2.0-preview (was: 2.0.0) > Improvements and fix ingestDB recov

[jira] [Updated] (FLINK-34085) Remove deprecated string configuration keys in Flink 2.0

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34085: --- Fix Version/s: 2.0-preview (was: 2.0.0) > Remove deprecated string configurat

[jira] [Updated] (FLINK-31608) Re-evaluate 'min-parallelism-increase' option

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31608: --- Fix Version/s: 2.0-preview (was: 2.0.0) > Re-evaluate 'min-parallelism-increa

Re: [PR] [FLINK-36474] Support merging timestamp columns when routing [flink-cdc]

2024-10-11 Thread via GitHub
aiwenmo commented on code in PR #3636: URL: https://github.com/apache/flink-cdc/pull/3636#discussion_r1797532737 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java: ## @@ -609,6 +643,34 @@ public Object getFieldOrNull(RecordData

[jira] [Updated] (FLINK-36001) Store operator name and UID in state metadata

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36001: --- Fix Version/s: 2.0-preview (was: 2.0.0) > Store operator name and UID in stat

[jira] [Updated] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35764: --- Fix Version/s: 2.0-preview (was: 2.0.0) > TimerGauge is incorrect when update

Re: [PR] [FLINK-36158][runtime] Refactor Job Recovery Process to Use ExecutionPlan Instead of JobGraph. [flink]

2024-10-11 Thread via GitHub
JunRuiLee commented on code in PR #25492: URL: https://github.com/apache/flink/pull/25492#discussion_r1797532597 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultExecutionPlanStore.java: ## @@ -109,153 +110,163 @@ public void stop() throws Exception {

[jira] [Updated] (FLINK-35795) FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35795: --- Fix Version/s: 2.0-preview (was: 2.0.0) > FLIP-466: Introduce ProcessFunction

Re: [PR] Add release announcement for Flink 2.0 Preview. [flink-web]

2024-10-11 Thread via GitHub
xintongsong commented on code in PR #754: URL: https://github.com/apache/flink-web/pull/754#discussion_r1797532551 ## docs/content/posts/2024-10-01-release-2.0-preview.md: ## @@ -0,0 +1,1264 @@ +--- +authors: +- xtsong: + name: "Xintong Song" +date: "2024-10-01T08:00:00Z" +subt

[jira] [Updated] (FLINK-36344) Introduce lastCheckpointCompletedTimestamp metrics

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36344: --- Fix Version/s: 2.0-preview (was: 2.0.0) > Introduce lastCheckpointCompletedTi

Re: [PR] [tests][ci] Refactor ci [flink-cdc]

2024-10-11 Thread via GitHub
yuxiqian commented on code in PR #3626: URL: https://github.com/apache/flink-cdc/pull/3626#discussion_r1797532444 ## .github/workflows/flink_cdc_base.yml: ## @@ -0,0 +1,235 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements

Re: [PR] Add release announcement for Flink 2.0 Preview. [flink-web]

2024-10-11 Thread via GitHub
xintongsong commented on code in PR #754: URL: https://github.com/apache/flink-web/pull/754#discussion_r1797532359 ## docs/content/posts/2024-10-01-release-2.0-preview.md: ## @@ -0,0 +1,1264 @@ +--- +authors: +- xtsong: + name: "Xintong Song" +date: "2024-10-01T08:00:00Z" +subt

[jira] [Updated] (FLINK-36064) Refactor REST API for Client and Operator Coordinator Communication to Use operatorUid.

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36064: --- Fix Version/s: 2.0-preview (was: 2.0.0) > Refactor REST API for Client and Op

[jira] [Updated] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36389: --- Fix Version/s: 2.0-preview (was: 2.0.0) > Fix DelegationTokenReceiverReposito

[jira] [Updated] (FLINK-36260) numBytesInLocal and numBuffersInLocal being reported as remote

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36260: --- Fix Version/s: 2.0-preview (was: 2.0.0) > numBytesInLocal and numBuffersInLoc

[jira] [Updated] (FLINK-23620) Introduce proper YAML parsing to Flink's configuration

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-23620: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > Introduce proper YAML parsing to Fl

[jira] [Updated] (FLINK-36334) Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses in flink-table-api-scala module

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36334: --- Fix Version/s: (was: 2.0-preview) > Remove the Disable markers from the tests in the various >

[jira] [Updated] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36378: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > type extraction problem between jav

[jira] [Updated] (FLINK-36511) FlinkSecurityManager#checkExit StackOverFlow if haltOnSystemExit is enabled

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36511: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > FlinkSecurityManager#checkExit Stac

[jira] [Updated] (FLINK-36277) Remove all direct uses of `TableEnvironmentInternal#registerTableSourceInternal` in table module

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36277: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > Remove all direct uses of > `Table

[jira] [Resolved] (FLINK-36265) List and track the deprecated APIs for the 2.0-preview release.

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-36265. Resolution: Done > List and track the deprecated APIs for the 2.0-preview release. > -

[jira] [Updated] (FLINK-36269) Remove `fromTableSource` in python module

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36269: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > Remove `fromTableSource` in python

[jira] [Updated] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes.

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36133: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > Remove subclass implementations of

[jira] [Updated] (FLINK-36134) Remove the classes associated with TableSource and TableSink as part of the optimization process.

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36134: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > Remove the classes associated with

[jira] [Updated] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc.

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36136: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > Remove TableSource & TableSink impl

[jira] [Updated] (FLINK-36135) Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc.

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36135: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > Remove the TableSource and TableSin

[jira] [Updated] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32483: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > RescaleCheckpointManuallyITCase.tes

[jira] [Updated] (FLINK-35573) [FLIP-447] Upgrade FRocksDB from 6.20.3 to 8.10.0

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35573: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > [FLIP-447] Upgrade FRocksDB from 6.

[jira] [Updated] (FLINK-36455) Sink should commit everything on notifyCheckpointCompleted

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36455: --- Fix Version/s: 2.0.0 (was: 2.0-preview) > Sink should commit everything on no

[jira] [Updated] (FLINK-34255) FLIP-406: Reorganize State & Checkpointing & Recovery Configuration

2024-10-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34255: --- Fix Version/s: 2.0.0 (was: 1.20.0) (was: 2.0-preview)

Re: [PR] Add release announcement for Flink 2.0 Preview. [flink-web]

2024-10-11 Thread via GitHub
xintongsong commented on code in PR #754: URL: https://github.com/apache/flink-web/pull/754#discussion_r1797530647 ## docs/content/posts/2024-10-01-release-2.0-preview.md: ## @@ -0,0 +1,1264 @@ +--- +authors: +- xtsong: + name: "Xintong Song" +date: "2024-10-01T08:00:00Z" +subt

[jira] [Commented] (FLINK-35670) Support Postgres CDC Pipeline Source

2024-10-11 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1703#comment-1703 ] ouyangwulin commented on FLINK-35670: - [~m.orazow]  Have you started the work? I che

Re: [PR] [fix][cdc-connector][mysql] Fix NoClassDefFoundError when create new table in mysql cdc source [flink-cdc]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #3036: URL: https://github.com/apache/flink-cdc/pull/3036#issuecomment-2408252374 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [FLINK-36024] Handle BinaryLogClient exceptions when searching for starting binlog offset [flink-cdc]

2024-10-11 Thread via GitHub
github-actions[bot] commented on PR #3524: URL: https://github.com/apache/flink-cdc/pull/3524#issuecomment-2408252298 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [FLINK-31380][table] Support enhanced show catalogs syntax [flink]

2024-10-11 Thread via GitHub
snuyanzin commented on code in PR #22179: URL: https://github.com/apache/flink/pull/22179#discussion_r1797339593 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlOtherOperationConverterTest.java: ## @@ -528,8 +558,8 @@ void testClearC

[jira] [Resolved] (FLINK-35075) Migrate TwoStageOptimizedAggregateRule

2024-10-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-35075. - Fix Version/s: 2.0-preview (was: 2.0.0) Resolution: Fixed

[jira] [Assigned] (FLINK-35075) Migrate TwoStageOptimizedAggregateRule

2024-10-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-35075: --- Assignee: Jacky Lau > Migrate TwoStageOptimizedAggregateRule >

Re: [PR] [FLINK-35075][table] Migrate TwoStageOptimizedAggregateRule to java [flink]

2024-10-11 Thread via GitHub
snuyanzin merged PR #24650: URL: https://github.com/apache/flink/pull/24650 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apa

[jira] [Commented] (FLINK-34163) Migrate SimplifyJoinConditionRule

2024-10-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888731#comment-17888731 ] Sergey Nuyanzin commented on FLINK-34163: - Merged as [4fd40be1385a1d1222dd4ad28

[jira] [Resolved] (FLINK-34163) Migrate SimplifyJoinConditionRule

2024-10-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-34163. - Fix Version/s: 2.0-preview Resolution: Fixed > Migrate SimplifyJoinConditionRule

Re: [PR] [FLINK-34163][table] Migration of SimplifyJoinConditionRule to java [flink]

2024-10-11 Thread via GitHub
snuyanzin merged PR #24145: URL: https://github.com/apache/flink/pull/24145 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apa

Re: [PR] [FLINK-36158][runtime] Refactor Job Recovery Process to Use ExecutionPlan Instead of JobGraph. [flink]

2024-10-11 Thread via GitHub
zhuzhurk commented on code in PR #25492: URL: https://github.com/apache/flink/pull/25492#discussion_r1797119386 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultExecutionPlanStore.java: ## @@ -109,153 +110,163 @@ public void stop() throws Exception {

[jira] [Closed] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering

2024-10-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36109. -- Resolution: Fixed merged to main d2c01737c745979c6aadb670334565ee11aa2f4a > Improve FlinkStateSnapsho

[jira] [Updated] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering

2024-10-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36109: --- Labels: pull-request-available (was: ) > Improve FlinkStateSnapshot resource labels for eff

Re: [PR] [FLINK-36109][snapshot] Add labels to snapshot resources [flink-kubernetes-operator]

2024-10-11 Thread via GitHub
gyfora merged PR #887: URL: https://github.com/apache/flink-kubernetes-operator/pull/887 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[jira] [Created] (FLINK-36512) Make rescale trigger based on failed checkpoints depend on the cause

2024-10-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-36512: - Summary: Make rescale trigger based on failed checkpoints depend on the cause Key: FLINK-36512 URL: https://issues.apache.org/jira/browse/FLINK-36512 Project: Flink

Re: [PR] [FLINK-36241] Table API .plus should support string concatenation [flink]

2024-10-11 Thread via GitHub
snuyanzin commented on code in PR #25298: URL: https://github.com/apache/flink/pull/25298#discussion_r1797059992 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/StringFunctionsITCase.java: ## @@ -44,10 +45,33 @@ Stream getTestSetSpecs()

Re: [PR] [FLINK-34467] bump flink version to 1.20.0 [flink-connector-kafka]

2024-10-11 Thread via GitHub
HuangZhenQiu commented on code in PR #111: URL: https://github.com/apache/flink-connector-kafka/pull/111#discussion_r1797032115 ## flink-connector-kafka/archunit-violations/86dfd459-67a9-4b26-9b5c-0b0bbf22681a: ## @@ -1,89 +1,5 @@ org.apache.flink.connector.kafka.sink.FlinkKaf

Re: [PR] [FLINK-36266][table] Insert into as select * behaves incorrect [flink]

2024-10-11 Thread via GitHub
snuyanzin commented on PR #25316: URL: https://github.com/apache/flink/pull/25316#issuecomment-2407516038 @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.

Re: [PR] [FLINK-36510][rpc] bump pekko to 1.1.2, remove netty 3 [flink]

2024-10-11 Thread via GitHub
gracegrimwood commented on PR #25494: URL: https://github.com/apache/flink/pull/25494#issuecomment-2407473348 @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 comm

Re: [PR] [FLINK-31380][table] Support enhanced show catalogs syntax [flink]

2024-10-11 Thread via GitHub
chucheng92 commented on PR #22179: URL: https://github.com/apache/flink/pull/22179#issuecomment-2407455991 hi @snuyanzin all comments resolved. If you have time, PTAL. thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] Bump org.apache.avro:avro from 1.11.3 to 1.11.4 [flink-connector-aws]

2024-10-11 Thread via GitHub
hlteoh37 merged PR #175: URL: https://github.com/apache/flink-connector-aws/pull/175 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@

[jira] [Commented] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

2024-10-11 Thread Edward Rojas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888650#comment-17888650 ] Edward Rojas commented on FLINK-28897: -- Hi [~lsy] any news on this issue or a possi

Re: [PR] [hotfix] Fix testfail due to data race with after migration to Fabric8 interceptor [flink-kubernetes-operator]

2024-10-11 Thread via GitHub
aplyusnin commented on PR #891: URL: https://github.com/apache/flink-kubernetes-operator/pull/891#issuecomment-2407386767 Yes, I close it -- 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 spec

Re: [PR] [hotfix] Fix testfail due to data race with after migration to Fabric8 interceptor [flink-kubernetes-operator]

2024-10-11 Thread via GitHub
aplyusnin closed pull request #891: [hotfix] Fix testfail due to data race with after migration to Fabric8 interceptor URL: https://github.com/apache/flink-kubernetes-operator/pull/891 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

Re: [PR] [BP-1.19][FLINK-35833][clients] Skip trying to create parents for "user.artifacts.base-dir" when fetching a "local://" artifact [flink]

2024-10-11 Thread via GitHub
flinkbot commented on PR #25500: URL: https://github.com/apache/flink/pull/25500#issuecomment-2407372457 ## CI report: * 2d32ee1742dbc9e9f610271909e6285584201bd6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35833) ArtifactFetchManager always creates artifact dir

2024-10-11 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-35833: - Component/s: Client / Job Submission (was: Deployment / Kubernetes) > Artif

[jira] [Commented] (FLINK-36446) Refactor Job Submission Process to Use ExecutionPlan Instead of JobGraph

2024-10-11 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888639#comment-17888639 ] david radley commented on FLINK-36446: -- [~JunRuiLi] I do not know this area well. I

Re: [PR] [BP-1.20][FLINK-35833][clients] Skip trying to create parents for "user.artifacts.base-dir" when fetching a "local://" artifact [flink]

2024-10-11 Thread via GitHub
flinkbot commented on PR #25499: URL: https://github.com/apache/flink/pull/25499#issuecomment-2407358124 ## CI report: * 96c06c652bbb02daee2565dd31bc17d99c3743fa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-36424) Update deprecated YARN RM/NM callback handlers

2024-10-11 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-36424: - Affects Version/s: 1.18.1 > Update deprecated YARN RM/NM callback handlers > ---

[jira] [Updated] (FLINK-36424) Update deprecated YARN RM/NM callback handlers

2024-10-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36424: --- Labels: pull-request-available (was: ) > Update deprecated YARN RM/NM callback handlers > -

Re: [PR] [FLINK-36424][yarn] Update deprecated YARN RM/NM callback handlers in YarnResourceManagerDriver [flink]

2024-10-11 Thread via GitHub
ferenc-csaky merged PR #25453: URL: https://github.com/apache/flink/pull/25453 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.

Re: [PR] [hotfix] Fix testfail due to data race with after migration to Fabric8 interceptor [flink-kubernetes-operator]

2024-10-11 Thread via GitHub
gyfora commented on PR #891: URL: https://github.com/apache/flink-kubernetes-operator/pull/891#issuecomment-2407321240 I think with @SamBarker 's PR merged, we can close this one right? -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[jira] [Closed] (FLINK-36471) Flink Operator uses out of date Docker actions.

2024-10-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36471. -- Resolution: Fixed merged to main 28fb28986fefcb729d95c9605ecf973058d59634 > Flink Operator uses out o

  1   2   >