Re: [PR] [FLINK-36586] upgrade flink cdc dependency flink version to 1.19 [flink-cdc]

2024-10-22 Thread via GitHub
yuxiqian commented on code in PR #3660: URL: https://github.com/apache/flink-cdc/pull/3660#discussion_r1811980681 ## pom.xml: ## @@ -69,9 +69,9 @@ limitations under the License. true -1.18.1 -1.18 -17.0 +1.19.1 +1.19 +

Re: [PR] [FLINK-36586] upgrade flink cdc dependency flink version to 1.19 [flink-cdc]

2024-10-22 Thread via GitHub
yuxiqian commented on code in PR #3660: URL: https://github.com/apache/flink-cdc/pull/3660#discussion_r1811980681 ## pom.xml: ## @@ -69,9 +69,9 @@ limitations under the License. true -1.18.1 -1.18 -17.0 +1.19.1 +1.19 +

Re: [PR] [FLINK-36586] upgrade flink cdc dependency flink version to 1.19 [flink-cdc]

2024-10-22 Thread via GitHub
yuxiqian commented on code in PR #3660: URL: https://github.com/apache/flink-cdc/pull/3660#discussion_r1811970827 ## flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/table/Db2ConnectorITCase.java: ## @@ -373,

Re: [PR] [FLINK-36586] upgrade flink cdc dependency flink version to 1.19 [flink-cdc]

2024-10-22 Thread via GitHub
yuxiqian commented on code in PR #3660: URL: https://github.com/apache/flink-cdc/pull/3660#discussion_r1811970085 ## flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/source/NewlyAddedTableITCase.java: ###

Re: [PR] [FLINK-36586] upgrade flink cdc dependency flink version to 1.19 [flink-cdc]

2024-10-22 Thread via GitHub
yuxiqian commented on code in PR #3660: URL: https://github.com/apache/flink-cdc/pull/3660#discussion_r1811970827 ## flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/java/org/apache/flink/cdc/connectors/db2/table/Db2ConnectorITCase.java: ## @@ -373,

[jira] [Updated] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-34466: Priority: Blocker (was: Minor) > Implement Lineage Interface in Kafka Connector > ---

[jira] [Assigned] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-34466: --- Assignee: Pawel Leszczynski (was: Zhenqiu Huang) > Implement Lineage Interface in Kafka Co

[jira] [Commented] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892059#comment-17892059 ] Arvid Heise commented on FLINK-34466: - Marking this as blocker for the upcoming kafk

[jira] [Updated] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-34466: Affects Version/s: kafka-3.4.0 (was: 1.20.0) > Implement Lineage Interf

[jira] [Updated] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-34466: Affects Version/s: 1.20.0 (was: 1.19.0) > Implement Lineage Interface i

[jira] [Comment Edited] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892058#comment-17892058 ] Arvid Heise edited comment on FLINK-34466 at 10/23/24 6:37 AM: ---

[jira] [Commented] (FLINK-34467) Implement Lineage Interface in Jdbc Connector

2024-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892057#comment-17892057 ] Arvid Heise commented on FLINK-34467: - Thanks for the pointer. The commit contained

[jira] [Commented] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892058#comment-17892058 ] Arvid Heise commented on FLINK-34466: - Merged version bump into main as 2dfdae6e8e44

[jira] (FLINK-34467) Implement Lineage Interface in Jdbc Connector

2024-10-22 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34467 ] Arvid Heise deleted comment on FLINK-34467: - was (Author: arvid): Merged version bump into main as 2dfdae6e8e44828a9c2b6db833348b65d9379b43. > Implement Lineage Interface in Jdbc Connector >

Re: [PR] [FLINK-24530][datastream] GlobalCommitter might not commit all records on drain [flink]

2024-10-22 Thread via GitHub
AHeise closed pull request #17536: [FLINK-24530][datastream] GlobalCommitter might not commit all records on drain URL: https://github.com/apache/flink/pull/17536 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

Re: [PR] Use maven version of mvn wrapper [flink-connector-shared-utils]

2024-10-22 Thread via GitHub
AHeise merged PR #41: URL: https://github.com/apache/flink-connector-shared-utils/pull/41 -- 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-unsubsc

Re: [PR] [FLINK-36379] Improve (Global)Committer with UC disabled [flink]

2024-10-22 Thread via GitHub
AHeise commented on PR #25456: URL: https://github.com/apache/flink/pull/25456#issuecomment-2431028900 @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. T

[jira] [Created] (FLINK-36590) Flink CDC does not Support MySQL > 8.0.x

2024-10-22 Thread yux (Jira)
yux created FLINK-36590: --- Summary: Flink CDC does not Support MySQL > 8.0.x Key: FLINK-36590 URL: https://issues.apache.org/jira/browse/FLINK-36590 Project: Flink Issue Type: Improvement Comp

Re: [PR] [FLINK-36523][Connectors/DynamoDB][BugFix] Fixing LATEST behaviour for DDB Connector [flink-connector-aws]

2024-10-22 Thread via GitHub
gguptp commented on code in PR #177: URL: https://github.com/apache/flink-connector-aws/pull/177#discussion_r1811947253 ## flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java: ## @@ -89,13 +9

Re: [PR] [FLINK-36523][Connectors/DynamoDB][BugFix] Fixing LATEST behaviour for DDB Connector [flink-connector-aws]

2024-10-22 Thread via GitHub
gguptp commented on code in PR #177: URL: https://github.com/apache/flink-connector-aws/pull/177#discussion_r1811945191 ## flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java: ## @@ -89,13 +9

Re: [PR] [FLINK-36523][Connectors/DynamoDB][BugFix] Fixing LATEST behaviour for DDB Connector [flink-connector-aws]

2024-10-22 Thread via GitHub
gguptp commented on code in PR #177: URL: https://github.com/apache/flink-connector-aws/pull/177#discussion_r1811943331 ## flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java: ## @@ -89,13 +9

[jira] [Commented] (FLINK-25822) Migrate away from using Source- and SinkFunctions for internal tests

2024-10-22 Thread Poorvank Bhatia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892052#comment-17892052 ] Poorvank Bhatia commented on FLINK-25822: - Hey, [~afedulov] , Is anyone working

Re: [PR] [FLINK-36523][Connectors/DynamoDB][BugFix] Fixing LATEST behaviour for DDB Connector [flink-connector-aws]

2024-10-22 Thread via GitHub
gguptp commented on code in PR #177: URL: https://github.com/apache/flink-connector-aws/pull/177#discussion_r1811942393 ## flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java: ## @

Re: [PR] [FLINK-36379] Improve (Global)Committer with UC disabled [flink]

2024-10-22 Thread via GitHub
AHeise commented on PR #25456: URL: https://github.com/apache/flink/pull/25456#issuecomment-2430999015 @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. T

Re: [PR] [FLINK-36379] Improve (Global)Committer with UC disabled [flink]

2024-10-22 Thread via GitHub
AHeise commented on PR #25456: URL: https://github.com/apache/flink/pull/25456#issuecomment-2430998750 > Thanks for addressing the comments % please double check that ` org.apache.flink.table.planner.runtime.stream.sql.TableSinkITCase.testSinkDisorderChangeLogWithRank` doesn't fail because

Re: [PR] [FLINK-4602][State] Move RocksDB statebackend classes to o.a.f.state.rocksdb package. [flink]

2024-10-22 Thread via GitHub
Zakelly commented on code in PR #25543: URL: https://github.com/apache/flink/pull/25543#discussion_r1811813185 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackendFactory.java: ## @@ -1,35 +1,10 @@

[jira] [Commented] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-22 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892039#comment-17892039 ] Feng Jin commented on FLINK-36569: -- [~ft20082]  Can you confirm which operator the leak

[jira] [Created] (FLINK-36589) Decouple the initialization of sync and async keyed statebackend

2024-10-22 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-36589: --- Summary: Decouple the initialization of sync and async keyed statebackend Key: FLINK-36589 URL: https://issues.apache.org/jira/browse/FLINK-36589 Project: Flink

[jira] [Created] (FLINK-36588) flink catalog is supported in cdc yaml

2024-10-22 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-36588: --- Summary: flink catalog is supported in cdc yaml Key: FLINK-36588 URL: https://issues.apache.org/jira/browse/FLINK-36588 Project: Flink Issue Type: New Feature

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

2024-10-22 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892035#comment-17892035 ] Yanfei Lei commented on FLINK-35029: Merged into master via 039a07d > Store timer i

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

2024-10-22 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35029. Resolution: Resolved > Store timer in JVM heap when async execution enabled >

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

2024-10-22 Thread via GitHub
fredia merged PR #25501: URL: https://github.com/apache/flink/pull/25501 -- 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.apache

[jira] [Commented] (FLINK-36414) NoSuchMethodError while trying flink cdc

2024-10-22 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892034#comment-17892034 ] ouyangwulin commented on FLINK-36414: - Try to use flink-1.18 > NoSuchMethodError wh

[jira] [Commented] (FLINK-36587) Postgres-cdc: Add support to override connector.class

2024-10-22 Thread Anil Dasari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892033#comment-17892033 ] Anil Dasari commented on FLINK-36587: - It seems that default values can be overridde

[jira] [Updated] (FLINK-36587) Postgres-cdc: Add support to override connector.class

2024-10-22 Thread Anil Dasari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anil Dasari updated FLINK-36587: Description: Debezium offers various interfaces, such as struct makers, connector tasks, and conn

[jira] [Created] (FLINK-36587) Postgres-cdc: Add support to override connector.class

2024-10-22 Thread Anil Dasari (Jira)
Anil Dasari created FLINK-36587: --- Summary: Postgres-cdc: Add support to override connector.class Key: FLINK-36587 URL: https://issues.apache.org/jira/browse/FLINK-36587 Project: Flink Issue Ty

[jira] [Commented] (FLINK-36587) Postgres-cdc: Add support to override connector.class

2024-10-22 Thread Anil Dasari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892030#comment-17892030 ] Anil Dasari commented on FLINK-36587: - Happy to raise the PR. Let me know. thanks.

Re: [PR] [FLINK-36575][runtime] ExecutionVertexInputInfo supports consuming subpartition groups [flink]

2024-10-22 Thread via GitHub
noorall commented on PR #25551: URL: https://github.com/apache/flink/pull/25551#issuecomment-2430701278 @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-36527][autoscaler] Introduce a parameter to support autoscaler adopt a more radical strategy when source vertex or upstream shuffle is keyBy [flink-kubernetes-operator]

2024-10-22 Thread via GitHub
SamBarker commented on code in PR #904: URL: https://github.com/apache/flink-kubernetes-operator/pull/904#discussion_r1811674080 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/NumKeyGroupsOrPartitionsParallelismAdjuster.java: ## @@ -0,0 +1,134 @@ +/* + * Licensed

Re: [PR] [FLINK-36527][autoscaler] Introduce a parameter to support autoscaler adopt a more radical strategy when source vertex or upstream shuffle is keyBy [flink-kubernetes-operator]

2024-10-22 Thread via GitHub
huyuanfeng2018 commented on code in PR #904: URL: https://github.com/apache/flink-kubernetes-operator/pull/904#discussion_r1811667427 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/NumKeyGroupsOrPartitionsParallelismAdjuster.java: ## @@ -0,0 +1,134 @@ +/* + * Lic

Re: [PR] [FLINK-36542] Enable upToDateChecking to speed up the spotless [flink]

2024-10-22 Thread via GitHub
ruanwenjun commented on PR #25525: URL: https://github.com/apache/flink/pull/25525#issuecomment-2430674613 > I think it'd be better to enable this by default (if there are concerns about CI, it could be disabled there), and also to upgrade the Spotless plugin version. > > The default

Re: [PR] [FLINK-25546][FOLLOWUP] Fix illegal file name [flink]

2024-10-22 Thread via GitHub
wForget commented on PR #25556: URL: https://github.com/apache/flink/pull/25556#issuecomment-2430673077 > 我说今天在家里Windows上怎么死活切不到master,原来是文件多了个空格哈哈 You can run `git config core. detect NTFS false` to bypass it. -- This is an automated message from the Apache Git Service. To respond

[jira] [Resolved] (FLINK-36458) Use original 'OceanBaseCEContainer' of testcontainers in testing

2024-10-22 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-36458. - Fix Version/s: jdbc-3.3.0 Assignee: He Wang Resolution: Fixed Merged to main(jdbc-3.3.0)

Re: [PR] [FLINK-36458] Upgrade testcontainers and use original OceanBaseCEContainer in testing [flink-connector-jdbc]

2024-10-22 Thread via GitHub
1996fanrui merged PR #144: URL: https://github.com/apache/flink-connector-jdbc/pull/144 -- 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] [Updated] (FLINK-36586) Upgrade Flink CDC dependency to Flink 1.19+

2024-10-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36586: --- Labels: pull-request-available (was: ) > Upgrade Flink CDC dependency to Flink 1.19+ >

[jira] [Created] (FLINK-36586) Upgrade Flink CDC dependency to Flink 1.19+

2024-10-22 Thread ZhengYu Chen (Jira)
ZhengYu Chen created FLINK-36586: Summary: Upgrade Flink CDC dependency to Flink 1.19+ Key: FLINK-36586 URL: https://issues.apache.org/jira/browse/FLINK-36586 Project: Flink Issue Type: New F

Re: [PR] Fix an exception:java.lang.NoClassDefFoundError: [flink-cdc]

2024-10-22 Thread via GitHub
tttzzzwww commented on PR #2501: URL: https://github.com/apache/flink-cdc/pull/2501#issuecomment-2430619392 @ariesy 您好,请问你本地解决这个问题了吗,我按您提交的配置修改了pom.xml,重新生成的jar包并没有额外添加的 com.ververica.cdc.connectors.shaded.org.apache.commons.collections -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop.

2024-10-22 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-36585: - Fix Version/s: 2.0.0 > The SplitFetcherManager.close() can chain the futures in a tight loop. >

[jira] [Assigned] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop.

2024-10-22 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-36585: Assignee: Jiangjie Qin > The SplitFetcherManager.close() can chain the futures in a tight

[jira] [Created] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop.

2024-10-22 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-36585: Summary: The SplitFetcherManager.close() can chain the futures in a tight loop. Key: FLINK-36585 URL: https://issues.apache.org/jira/browse/FLINK-36585 Project: Flink

Re: [PR] [FLINK-36527][autoscaler] Introduce a parameter to support autoscaler adopt a more radical strategy when source vertex or upstream shuffle is keyBy [flink-kubernetes-operator]

2024-10-22 Thread via GitHub
SamBarker commented on code in PR #904: URL: https://github.com/apache/flink-kubernetes-operator/pull/904#discussion_r1811604794 ## flink-autoscaler/src/test/java/org/apache/flink/autoscaler/JobVertexScalerTest.java: ## @@ -1004,6 +1036,38 @@ public void testNumPartitionsAdjust

Re: [PR] [FLINK-36332] Missed webhook okhttp reference. [flink-kubernetes-operator]

2024-10-22 Thread via GitHub
SamBarker commented on PR #906: URL: https://github.com/apache/flink-kubernetes-operator/pull/906#issuecomment-2430558964 I've added eede213 to address the issues highlighted by @k-wall ```shell mvn help:effective-pom -pl :flink-kubernetes-operator -Doutput=/tmp/default-pom.xml

Re: [PR] [hotfix][python] Fix PyFlink JdbcSink wrong Java Class Name [flink]

2024-10-22 Thread via GitHub
Al-Moatasem closed pull request #25214: [hotfix][python] Fix PyFlink JdbcSink wrong Java Class Name URL: https://github.com/apache/flink/pull/25214 -- 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 th

Re: [PR] [FLINK-36332] Missed webhook okhttp reference. [flink-kubernetes-operator]

2024-10-22 Thread via GitHub
SamBarker commented on PR #906: URL: https://github.com/apache/flink-kubernetes-operator/pull/906#issuecomment-2430283052 Thanks @k-wall > I think `depend-on-okhttp4` should be activated by default. If a user wants a alternative client, they should set the `fabric8.httpclient.impl`

Re: [PR] [FLINK-36332] Missed webhook okhttp reference. [flink-kubernetes-operator]

2024-10-22 Thread via GitHub
SamBarker commented on code in PR #906: URL: https://github.com/apache/flink-kubernetes-operator/pull/906#discussion_r1811403061 ## flink-kubernetes-webhook/pom.xml: ## @@ -24,7 +24,7 @@ under the License. org.apache.flink flink-kubernetes-operator-parent

Re: [PR] [FLINK-36542] Enable upToDateChecking to speed up the spotless [flink]

2024-10-22 Thread via GitHub
jnh5y commented on PR #25525: URL: https://github.com/apache/flink/pull/25525#issuecomment-2430105599 I think it'd be better to enable this by default (if there are concerns about CI, it could be disabled there), and also to upgrade the Spotless plugin version. The default is for thi

[jira] [Created] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots

2024-10-22 Thread Anil Dasari (Jira)
Anil Dasari created FLINK-36584: --- Summary: PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots Key: FLINK-36584 URL: https://issues.apac

[jira] [Assigned] (FLINK-36583) Add Slow Request Kube Client Metrics

2024-10-22 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi reassigned FLINK-36583: - Assignee: Matyas Orhidi > Add Slow Request Kube Client Metrics > --

[jira] [Created] (FLINK-36583) Add Slow Request Kube Client Metrics

2024-10-22 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-36583: - Summary: Add Slow Request Kube Client Metrics Key: FLINK-36583 URL: https://issues.apache.org/jira/browse/FLINK-36583 Project: Flink Issue Type: Improvemen

Re: [PR] [FLINK-33722] Fix events ordering in MATCH_RECOGNIZE in batch mode [flink]

2024-10-22 Thread via GitHub
dawidwys commented on code in PR #24699: URL: https://github.com/apache/flink/pull/24699#discussion_r1811139271 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecMatch.java: ## @@ -51,7 +71,95 @@ public BatchExecMatch(

Re: [PR] [FLINK-33722] Fix events ordering in MATCH_RECOGNIZE in batch mode [flink]

2024-10-22 Thread via GitHub
dawidwys commented on code in PR #24699: URL: https://github.com/apache/flink/pull/24699#discussion_r1811135576 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecMatch.java: ## @@ -51,7 +71,95 @@ public BatchExecMatch(

[jira] [Closed] (FLINK-36543) Table API over windows cannot be string serialized

2024-10-22 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-36543. Resolution: Fixed Fixed in: * master ** 55cc36a81553523b90b58d89c11ec5ba495f23f4 * 1.20 **

[jira] [Created] (FLINK-36582) sql client hang when querying a parquet table

2024-10-22 Thread Lu Niu (Jira)
Lu Niu created FLINK-36582: -- Summary: sql client hang when querying a parquet table Key: FLINK-36582 URL: https://issues.apache.org/jira/browse/FLINK-36582 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-29065) Flink v1.15.1 contains netty(version:3.10.6). There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. thx

2024-10-22 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-29065: - Affects Version/s: 1.19.1 1.18.1 1.17.2

[jira] [Updated] (FLINK-36582) sql client hang when querying a parquet table

2024-10-22 Thread Lu Niu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu Niu updated FLINK-36582: --- Attachment: sql_client_jstack_1 > sql client hang when querying a parquet table > --

[jira] [Closed] (FLINK-29065) Flink v1.15.1 contains netty(version:3.10.6). There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. thx

2024-10-22 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky closed FLINK-29065. Fix Version/s: 2.0.0 1.20.1 Resolution: Fixed > Flink v1.15.1 contains n

[jira] [Closed] (FLINK-36510) Upgrade Pekko from 1.0.1 to 1.1.2

2024-10-22 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky closed FLINK-36510. Resolution: Fixed [{{a83f24f}}|https://github.com/apache/flink/commit/a83f24f9926e4a2830db42adedbe

Re: [PR] [FLINK-36510][rpc] bump pekko to 1.1.2, remove netty 3 (backport to release-1.20) [flink]

2024-10-22 Thread via GitHub
ferenc-csaky merged PR #25550: URL: https://github.com/apache/flink/pull/25550 -- 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] [FLINK-36510][rpc] bump pekko to 1.1.2, remove netty 3 [flink]

2024-10-22 Thread via GitHub
ferenc-csaky merged PR #25494: URL: https://github.com/apache/flink/pull/25494 -- 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] [FLINK-36332] Missed webhook okhttp reference. [flink-kubernetes-operator]

2024-10-22 Thread via GitHub
k-wall commented on PR #906: URL: https://github.com/apache/flink-kubernetes-operator/pull/906#issuecomment-2429777651 I think there is a misunderstand about the way that Maven profiles are activated. Maven profile can be activated by [system properties](https://maven.apache.org/guides/in

[PR] [FLINK-36502] [TABLE-SQL] Remove deprecated methods in FactoryUtil. [flink]

2024-10-22 Thread via GitHub
Sud0x67 opened a new pull request, #25559: URL: https://github.com/apache/flink/pull/25559 ## What is the purpose of the change [[FLINK-36476](https://issues.apache.org/jira/browse/FLINK-36476)](https://issues.apache.org/jira/browse/FLINK-36476) Remove all deprecated methods under pu

[jira] [Updated] (FLINK-36502) Remove all deprecated methods in `FactoryUtil`

2024-10-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36502: --- Labels: pull-request-available (was: ) > Remove all deprecated methods in `FactoryUtil` > -

Re: [PR] [FLINK-36502] [TABLE-SQL] Remove deprecated methods in FactoryUtil. [flink]

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

[jira] [Commented] (FLINK-36502) Remove all deprecated methods in `FactoryUtil`

2024-10-22 Thread Shengbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891910#comment-17891910 ] Shengbo commented on FLINK-36502: - https://github.com/apache/flink/pull/25559 > Remove

Re: [PR] [FLINK-36521][runtime] Introduce TtlAwareSerializer and TtlAwareSerializerSnapshot [flink]

2024-10-22 Thread via GitHub
xiangyuf commented on PR #25554: URL: https://github.com/apache/flink/pull/25554#issuecomment-2429639550 @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-36523][Connectors/DynamoDB][BugFix] Fixing LATEST behaviour for DDB Connector [flink-connector-aws]

2024-10-22 Thread via GitHub
hlteoh37 commented on code in PR #177: URL: https://github.com/apache/flink-connector-aws/pull/177#discussion_r1810789785 ## flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java: ##

Re: [PR] [BP-1.20][docs] Update Java 17 compatibility docs [flink]

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

Re: [PR] [BP-1.19][docs] Update Java 17 compatibility docs [flink]

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

[PR] [docs] Update Java 17 compatibility docs [flink]

2024-10-22 Thread via GitHub
ferenc-csaky opened a new pull request, #25558: URL: https://github.com/apache/flink/pull/25558 Trivial docs backport of https://github.com/apache/flink/pull/25342 to 1.19. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[PR] [BP-1.20][docs] Update Java 17 compatibility docs [flink]

2024-10-22 Thread via GitHub
ferenc-csaky opened a new pull request, #25557: URL: https://github.com/apache/flink/pull/25557 Trivial docs backport. -- 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 un

Re: [PR] [FLINK-4602][State] Move RocksDB statebackend classes to o.a.f.state.rocksdb package. [flink]

2024-10-22 Thread via GitHub
AlexYinHan commented on PR #25543: URL: https://github.com/apache/flink/pull/25543#issuecomment-2429273295 @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] [hotfix][Table SQL / API] fix create table from values decimal issue [flink]

2024-10-22 Thread via GitHub
dylanhz commented on code in PR #24981: URL: https://github.com/apache/flink/pull/24981#discussion_r1810623732 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/ValueDataTypeConverter.java: ## @@ -119,8 +121,8 @@ private static DataType convertTo

Re: [PR] [FLINK-35136] Bump connector version to 4.0, adapt CI workflows [flink-connector-hbase]

2024-10-22 Thread via GitHub
ferenc-csaky commented on PR #46: URL: https://github.com/apache/flink-connector-hbase/pull/46#issuecomment-2429102827 @JuliaBogdan FYI started the discussion, it can be followed [here](https://lists.apache.org/thread/rsdrwv2vz2y83lco9wkxbx7l9rcbqxpv). -- This is an automated message fro

[jira] [Commented] (FLINK-36543) Table API over windows cannot be string serialized

2024-10-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891817#comment-17891817 ] Martijn Visser commented on FLINK-36543: [~dwysakowicz] Don't forget to close th

Re: [PR] [FLINK-36332] Missed webhook okhttp reference. [flink-kubernetes-operator]

2024-10-22 Thread via GitHub
tinaselenge commented on code in PR #906: URL: https://github.com/apache/flink-kubernetes-operator/pull/906#discussion_r1810557209 ## flink-kubernetes-webhook/pom.xml: ## @@ -24,7 +24,7 @@ under the License. org.apache.flink flink-kubernetes-operator-parent

[jira] [Commented] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink

2024-10-22 Thread Poorvank Bhatia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891794#comment-17891794 ] Poorvank Bhatia commented on FLINK-26821: - Hey [~rmetzger], If this is not alrea

Re: [PR] [FLINK-36065][runtime] Support submit stream graph. [flink]

2024-10-22 Thread via GitHub
zhuzhurk commented on code in PR #25472: URL: https://github.com/apache/flink/pull/25472#discussion_r1810402076 ## flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java: ## @@ -393,9 +393,9 @@ private void setBatchStateBackendAndTimerService

[jira] [Assigned] (FLINK-35282) PyFlink Support for Apache Beam > 2.49

2024-10-22 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-35282: --- Assignee: Dimitris Stafylarakis (was: Antonio Vespoli) > PyFlink Support for Apach

Re: [PR] [hotfix][docs] Add FlinkStateSnapshot to upgrade docs [flink-kubernetes-operator]

2024-10-22 Thread via GitHub
gyfora merged PR #905: URL: https://github.com/apache/flink-kubernetes-operator/pull/905 -- 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-36194) Shutdown hook for ExecutionGraphInfo store runs concurrently to cluster shutdown hook causing race conditions

2024-10-22 Thread Eaugene Thomas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891786#comment-17891786 ] Eaugene Thomas commented on FLINK-36194: can you help with the review [~mapohl]

[jira] [Created] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters

2024-10-22 Thread LvYanquan (Jira)
LvYanquan created FLINK-36581: - Summary: Allow passing Flink configuration by yaml job file or command line parameters Key: FLINK-36581 URL: https://issues.apache.org/jira/browse/FLINK-36581 Project: Flin

Re: [PR] Remove jdk8 from 2.0-preview1 [flink-docker]

2024-10-22 Thread via GitHub
reswqa merged PR #208: URL: https://github.com/apache/flink-docker/pull/208 -- 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

[PR] Remove jdk8 from 2.0-preview1 [flink-docker]

2024-10-22 Thread via GitHub
reswqa opened a new pull request, #208: URL: https://github.com/apache/flink-docker/pull/208 (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 unsubscribe, e-

Re: [PR] Update Dockerfiles for 2.0-preview1 release [flink-docker]

2024-10-22 Thread via GitHub
reswqa merged PR #207: URL: https://github.com/apache/flink-docker/pull/207 -- 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] Add GPG key for 2.0-preview1 release [flink-docker]

2024-10-22 Thread via GitHub
reswqa merged PR #206: URL: https://github.com/apache/flink-docker/pull/206 -- 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-36506: Remove all deprecated methods in `ColumnStats` [flink]

2024-10-22 Thread via GitHub
atu-sharm commented on PR #2: URL: https://github.com/apache/flink/pull/2#issuecomment-2428646677 @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-36506: Remove all deprecated methods in `ColumnStats` [flink]

2024-10-22 Thread via GitHub
atu-sharm commented on PR #2: URL: https://github.com/apache/flink/pull/2#issuecomment-2428621771 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Updated] (FLINK-36579) mysql cdc charset collation sort not equals java string compare.

2024-10-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36579: --- Labels: pull-request-available (was: ) > mysql cdc charset collation sort not equals java s

[PR] Add GPG key for 2.0-preview1 release [flink-docker]

2024-10-22 Thread via GitHub
reswqa opened a new pull request, #206: URL: https://github.com/apache/flink-docker/pull/206 (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 unsubscribe, e-

[jira] [Created] (FLINK-36580) Using debezium.column.exclude.list causes job failure

2024-10-22 Thread MOBIN (Jira)
MOBIN created FLINK-36580: - Summary: Using debezium.column.exclude.list causes job failure Key: FLINK-36580 URL: https://issues.apache.org/jira/browse/FLINK-36580 Project: Flink Issue Type: Bug

  1   2   >