[jira] [Updated] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python

2025-02-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-36900: --- Fix Version/s: 2.1.0 > Migrate away from Anaconda for managing Python environments for Flink

[jira] [Commented] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python

2025-02-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926293#comment-17926293 ] Martijn Visser commented on FLINK-36900: Merged in apache/flink:master 7d3588d50

Re: [PR] [FLINK-36900][python] Migrate from conda to uv for managing Python environments for PyFlink [flink]

2025-02-11 Thread via GitHub
MartijnVisser merged PR #26065: URL: https://github.com/apache/flink/pull/26065 -- 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-37005][table] Make StreamExecDeduplicate ouput insert only where possible [flink]

2025-02-11 Thread via GitHub
pnowojski commented on code in PR #26051: URL: https://github.com/apache/flink/pull/26051#discussion_r1952125243 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecDeduplicate.java: ## @@ -339,25 +362,39 @@ OneInputSt

Re: [PR] [hotfix] Make nightly tests passing for jdk 17+ [flink-connector-elasticsearch]

2025-02-11 Thread via GitHub
reswqa merged PR #117: URL: https://github.com/apache/flink-connector-elasticsearch/pull/117 -- 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] [Created] (FLINK-37308) HybridSourceReader doesn't support pauseOrResumeSplits

2025-02-11 Thread Xingcan Cui (Jira)
Xingcan Cui created FLINK-37308: --- Summary: HybridSourceReader doesn't support pauseOrResumeSplits Key: FLINK-37308 URL: https://issues.apache.org/jira/browse/FLINK-37308 Project: Flink Issue Ty

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

2025-02-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36167: --- Affects Version/s: 2.0.0 2.1.0 > testSinkDisorderChangeLog failed on AZP > --

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

2025-02-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-36167: -- Assignee: Shuai Xu > testSinkDisorderChangeLog failed on AZP > --

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

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

[jira] [Commented] (FLINK-37248) Scala was removed in flink 2.0

2025-02-11 Thread 911432 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926275#comment-17926275 ] 911432 commented on FLINK-37248: [~Zhanghao Chen]  I hope this external documentation wi

[jira] [Assigned] (FLINK-37305) JDBC Connector CI failed due to network issue

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37305: -- Assignee: yux > JDBC Connector CI failed due to network issue > -

Re: [PR] [FLINK-36604][datastream] StreamingJobGraphGenerator::setOperatorConfig checks input serializer length [flink]

2025-02-11 Thread via GitHub
reswqa commented on PR #25576: URL: https://github.com/apache/flink/pull/25576#issuecomment-2652739916 Could you share the example job that make this check unhappy? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[jira] [Commented] (FLINK-37248) Scala was removed in flink 2.0

2025-02-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926265#comment-17926265 ] Zhanghao Chen commented on FLINK-37248: --- [~911432] These connectors are externaliz

[jira] [Commented] (FLINK-37047) Cross-team verification for "Remove DataSet API"

2025-02-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926264#comment-17926264 ] Zhanghao Chen commented on FLINK-37047: --- [~yyhx] Thanks for the clarification, LGT

[jira] [Commented] (FLINK-37119) Bump the version of Paimon flink to 1.0.0

2025-02-11 Thread 911432 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926259#comment-17926259 ] 911432 commented on FLINK-37119: What is the minimum version that flink cdc 3.4.X suppor

Re: [PR] [MINOR] Deprecated StreamSink and SinkOperator [flink]

2025-02-11 Thread via GitHub
beliefer commented on PR #25835: URL: https://github.com/apache/flink/pull/25835#issuecomment-2652603360 cc @1996fanrui -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

Re: [PR] [hotfix][tests] Fix MySQLSourceITCase failure in non-UTC timezone [flink-cdc]

2025-02-11 Thread via GitHub
leonardBang commented on PR #3917: URL: https://github.com/apache/flink-cdc/pull/3917#issuecomment-2652598974 https://issues.apache.org/jira/browse/FLINK-37306 Could you link to this ticket ? -- This is an automated message from the Apache Git Service. To respond to the message, please lo

Re: [PR] [hotfix][tests] Fix MySQLSourceITCase failure in non-UTC timezone [flink-cdc]

2025-02-11 Thread via GitHub
yuxiqian commented on PR #3917: URL: https://github.com/apache/flink-cdc/pull/3917#issuecomment-2652588333 @leonardBang @lvyanquan PTAL -- 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 specifi

[jira] [Commented] (FLINK-37305) JDBC Connector CI failed due to network issue

2025-02-11 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926253#comment-17926253 ] yux commented on FLINK-37305: - I've spotted similar error in Flink CDC CI. Would like to inv

Re: [PR] [BP-2.0][FLINK-37301][state/forst] Fix wrong flag returned by `ForStStateBackend#supportsSavepointFormat` [flink]

2025-02-11 Thread via GitHub
flinkbot commented on PR #26146: URL: https://github.com/apache/flink/pull/26146#issuecomment-2652561849 ## CI report: * edf3608918226224383d99dd4dc056af29ff0525 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-37307) Flink CDC CI failed due to OceanBaseE2eITCase

2025-02-11 Thread JunboWang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JunboWang updated FLINK-37307: -- Description: [https://github.com/apache/flink-cdc/actions/runs/13260216427/job/37067737782?pr=3914|htt

[jira] [Updated] (FLINK-37307) Flink CDC CI failed due to OceanBaseE2eITCase

2025-02-11 Thread JunboWang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JunboWang updated FLINK-37307: -- Description: [https://github.com/apache/flink-cdc/actions/runs/13260216427/job/37067737782?pr=3914|htt

Re: [PR] [BP-2.0][FLINK-37021][state/forst] Support reusing files in LEGACY recovery mode [flink]

2025-02-11 Thread via GitHub
flinkbot commented on PR #26147: URL: https://github.com/apache/flink/pull/26147#issuecomment-2652573528 ## CI report: * 363321365279285800079d9f8e2880b830715672 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-37307) Flink CDC CI failed due to OceanBaseE2eITCase

2025-02-11 Thread JunboWang (Jira)
JunboWang created FLINK-37307: - Summary: Flink CDC CI failed due to OceanBaseE2eITCase Key: FLINK-37307 URL: https://issues.apache.org/jira/browse/FLINK-37307 Project: Flink Issue Type: Improveme

Re: [PR] [hotfix][state/forst] Make file cache options recognize size type [flink]

2025-02-11 Thread via GitHub
flinkbot commented on PR #26148: URL: https://github.com/apache/flink/pull/26148#issuecomment-2652573635 ## CI report: * 0310a082e445db99843ddd964d4180906b562ecf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-37306) Flink CDC CI failed due to timezone shift

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926250#comment-17926250 ] Leonard Xu commented on FLINK-37306: [~Lv Yanquan]Would you like to investigate this

[jira] [Created] (FLINK-37306) Flink CDC CI failed due to timezone shift

2025-02-11 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-37306: -- Summary: Flink CDC CI failed due to timezone shift Key: FLINK-37306 URL: https://issues.apache.org/jira/browse/FLINK-37306 Project: Flink Issue Type: Bug Aff

Re: [PR] [MINOR] Rename PunctuatedWatermarkStrategyWrapper with PunctuatedWatermarkAssignerWrapper [flink]

2025-02-11 Thread via GitHub
beliefer commented on PR #25836: URL: https://github.com/apache/flink/pull/25836#issuecomment-2652564190 @1996fanrui @davidradl Thank you! -- 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

[PR] [hotfix][state/forst] Make file cache options recognize size type [flink]

2025-02-11 Thread via GitHub
Zakelly opened a new pull request, #26148: URL: https://github.com/apache/flink/pull/26148 ## What is the purpose of the change Currently, the file cache options `state.backend.forst.cache.reserve-size` and `state.backend.forst.cache.size-based-limit` are long type, which are not rea

[jira] [Commented] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

2025-02-11 Thread Yanquan Lv (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926246#comment-17926246 ] Yanquan Lv commented on FLINK-37304: I would like to take this. > Dynamic Kafka Sou

[PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc]

2025-02-11 Thread via GitHub
MOBIN-F opened a new pull request, #3918: URL: https://github.com/apache/flink-cdc/pull/3918 At present, FlinkCDC only supports reading Flink configurations from Flink con files, but this approach is not user-friendly for multiple jobs that require different configurations. Allow passing Fl

[jira] [Updated] (FLINK-37305) JDBC Connector CI failed due to network issue

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37305: --- Labels: newbiee (was: ) > JDBC Connector CI failed due to network issue > -

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

2025-02-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36581: --- Labels: pull-request-available (was: ) > Allow passing Flink configuration by yaml job file

[jira] [Created] (FLINK-37305) JDBC Connector CI failed due to network issue

2025-02-11 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-37305: -- Summary: JDBC Connector CI failed due to network issue Key: FLINK-37305 URL: https://issues.apache.org/jira/browse/FLINK-37305 Project: Flink Issue Type: Bug

Re: [PR] Add Flink 1.19.2 release [flink-web]

2025-02-11 Thread via GitHub
leonardBang commented on code in PR #771: URL: https://github.com/apache/flink-web/pull/771#discussion_r1951908382 ## docs/content/posts/2025-02-TBD-release-1.19.2.md: ## @@ -0,0 +1,212 @@ +--- +title: "Apache Flink 1.19.2 Release Announcement" +date: "2025-02-TBDT00:00:00.000Z

[PR] [FLINK-37021][state/forst] Support reusing files in LEGACY recovery mode [flink]

2025-02-11 Thread via GitHub
AlexYinHan opened a new pull request, #26147: URL: https://github.com/apache/flink/pull/26147 ## What is the purpose of the change To support ForStDB reusing files when restoring in LEGACY mode. ## Brief change log - Make ```DataTransferStrategyBuilder```

[jira] [Commented] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926247#comment-17926247 ] Leonard Xu commented on FLINK-37304: Thanks [~kunni] for the quick response! assigne

[jira] [Assigned] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37304: -- Assignee: Yanquan Lv > Dynamic Kafka Source logs credentials in plaintext under INFO > --

Re: [PR] [FLINK-37278] Optimize regular schema evolution topology's performance [flink-cdc]

2025-02-11 Thread via GitHub
Shawn-Hx commented on code in PR #3912: URL: https://github.com/apache/flink-cdc/pull/3912#discussion_r1951890862 ## flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaCoordinator.java: ## @@ -219,73 +227,14 @@ protected void handleUnreco

[jira] [Updated] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37304: --- Priority: Blocker (was: Major) > Dynamic Kafka Source logs credentials in plaintext under INFO > --

[jira] [Created] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

2025-02-11 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-37304: -- Summary: Dynamic Kafka Source logs credentials in plaintext under INFO Key: FLINK-37304 URL: https://issues.apache.org/jira/browse/FLINK-37304 Project: Flink Is

[jira] [Commented] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat

2025-02-11 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926244#comment-17926244 ] Zakelly Lan commented on FLINK-37301: - Master: 62c0899f48e831a0510a6e030bcc5c8fd1583

[jira] [Assigned] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat

2025-02-11 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-37301: --- Assignee: Zakelly Lan > Fix wrong flag returned by ForStStateBackend#supportsSavepointForma

[jira] [Updated] (FLINK-35134) Release flink-connector-elasticsearch v3.2.0 for Flink 1.19 and Flink 1.20

2025-02-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35134: --- Summary: Release flink-connector-elasticsearch v3.2.0 for Flink 1.19 and Flink 1.20 (was: Release f

[PR] [BP-2.0][FLINK-37301][state/forst] Fix wrong flag returned by `ForStStateBackend#supportsSavepointFormat` [flink]

2025-02-11 Thread via GitHub
Zakelly opened a new pull request, #26146: URL: https://github.com/apache/flink/pull/26146 ## What is the purpose of the change The `ForStStateBackend` did not override the `supportsSavepointFormat`, which means it gives the wrong flag. We should fix this. ## Brief change l

Re: [PR] [FLINK-37301][state/forst] Fix wrong flag returned by `ForStStateBackend#supportsSavepointFormat` [flink]

2025-02-11 Thread via GitHub
Zakelly merged PR #26143: URL: https://github.com/apache/flink/pull/26143 -- 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.apach

[jira] [Comment Edited] (FLINK-37021) Implement fast checkpoint/rescaling for ForStKeyedStateBackend

2025-02-11 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923962#comment-17923962 ] Zakelly Lan edited comment on FLINK-37021 at 2/12/25 2:26 AM:

Re: [PR] [FLINK-37021][state/forst] Support reusing files in LEGACY recovery mode [flink]

2025-02-11 Thread via GitHub
Zakelly merged PR #26142: URL: https://github.com/apache/flink/pull/26142 -- 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.apach

Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc]

2025-02-11 Thread via GitHub
beryllw commented on PR #3856: URL: https://github.com/apache/flink-cdc/pull/3856#issuecomment-2652477654 CI https://github.com/beryllw/flink-cdc/actions/runs/13276446389. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

Re: [PR] [MINOR] Rename PunctuatedWatermarkStrategyWrapper with PunctuatedWatermarkAssignerWrapper [flink]

2025-02-11 Thread via GitHub
1996fanrui merged PR #25836: URL: https://github.com/apache/flink/pull/25836 -- 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.ap

[jira] [Comment Edited] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19

2025-02-11 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925923#comment-17925923 ] Weijie Guo edited comment on FLINK-35134 at 2/12/25 1:49 AM: -

Re: [PR] [FLINK-37005][table] Make StreamExecDeduplicate ouput insert only where possible [flink]

2025-02-11 Thread via GitHub
xuyangzhong commented on code in PR #26051: URL: https://github.com/apache/flink/pull/26051#discussion_r1951860691 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecDeduplicate.java: ## @@ -339,25 +362,39 @@ OneInput

[PR] [hotfix][tests] Fix MySQLSourceITCase failure in non-UTC timezone [flink-cdc]

2025-02-11 Thread via GitHub
yuxiqian opened a new pull request, #3917: URL: https://github.com/apache/flink-cdc/pull/3917 The failing test cases were introduced in #3298 and #3876, but has not been exposed until we decided to run CI test cases in random timezones (#3650). MySQL docker container runs in UTC timez

Re: [PR] [FLINK-37201] [cdc] [transform] FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types [flink-cdc]

2025-02-11 Thread via GitHub
aiwenmo commented on PR #3881: URL: https://github.com/apache/flink-cdc/pull/3881#issuecomment-2652448660 @leonardBang Sorry. Please help me trigger it after resolving the exception on the master branch. -- This is an automated message from the Apache Git Service. To respond to the messag

Re: [PR] [FLINK-37201] [cdc] [transform] FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types [flink-cdc]

2025-02-11 Thread via GitHub
aiwenmo commented on PR #3881: URL: https://github.com/apache/flink-cdc/pull/3881#issuecomment-2652420037 Hi @leonardBang , I have rebased master. Could you help trigger the actions again? thx -- This is an automated message from the Apache Git Service. To respond to the message, plea

Re: [PR] Lc.finished state batch issue 1.10 [flink-kubernetes-operator]

2025-02-11 Thread via GitHub
luca-p-castelli closed pull request #942: Lc.finished state batch issue 1.10 URL: https://github.com/apache/flink-kubernetes-operator/pull/942 -- 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

[PR] Lc.finished state batch issue 1.10 [flink-kubernetes-operator]

2025-02-11 Thread via GitHub
luca-p-castelli opened a new pull request, #942: URL: https://github.com/apache/flink-kubernetes-operator/pull/942 ## What is the purpose of the change *(For example: This pull request adds a new feature to periodically create and maintain savepoints through the `FlinkDeployme

Re: [PR] [hotfix] Integrate hive connector docs [flink]

2025-02-11 Thread via GitHub
afedulov commented on PR #26135: URL: https://github.com/apache/flink/pull/26135#issuecomment-2652226097 @snuyanzin thanks for asking. RC1 was accepted, I do not expect us incorporating changes from release-1.20 branch, so feel free to merge. -- This is an automated message from the Apach

Re: [PR] Add Hive 3.0.0 connector [flink-web]

2025-02-11 Thread via GitHub
snuyanzin merged PR #709: URL: https://github.com/apache/flink-web/pull/709 -- 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] [Updated] (FLINK-37303) Bump guava to 33.4.0

2025-02-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37303: --- Labels: pull-request-available (was: ) > Bump guava to 33.4.0 > > >

[jira] [Created] (FLINK-37303) Bump guava to 33.4.0

2025-02-11 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-37303: --- Summary: Bump guava to 33.4.0 Key: FLINK-37303 URL: https://issues.apache.org/jira/browse/FLINK-37303 Project: Flink Issue Type: Technical Debt Aff

Re: [PR] [FLINK-35014] SqlNode to operation conversion for models [flink]

2025-02-11 Thread via GitHub
lihaosky commented on PR #25834: URL: https://github.com/apache/flink/pull/25834#issuecomment-2651969124 @flinkbot run azure re-run the last Azure build -- 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

Re: [PR] [FLINK-35014] SqlNode to operation conversion for models [flink]

2025-02-11 Thread via GitHub
lihaosky commented on PR #25834: URL: https://github.com/apache/flink/pull/25834#issuecomment-2651967293 @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] [Commented] (FLINK-37271) Add network channel reconnect capability

2025-02-11 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926063#comment-17926063 ] Zhenqiu Huang commented on FLINK-37271: --- Yes, that is exactly the requirement. We

Re: [PR] [FLINK-36900][python] Migrate from conda to uv for managing Python environments for PyFlink [flink]

2025-02-11 Thread via GitHub
MartijnVisser commented on code in PR #26065: URL: https://github.com/apache/flink/pull/26065#discussion_r1951160748 ## flink-python/README.md: ## @@ -43,30 +43,30 @@ PyFlink depends on the following libraries to execute the above script: 2. setuptools (>=37.0.0) 3. pip (>=20

Re: [PR] [FLINK-37269][table] Add new DESCRIPTOR type [flink]

2025-02-11 Thread via GitHub
twalthr commented on code in PR #26144: URL: https://github.com/apache/flink/pull/26144#discussion_r1951134371 ## flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/type/SqlTypeAssignmentRule.java: ## @@ -0,0 +1,236 @@ +/* + * Licensed to the Apache Software Fo

Re: [PR] [FLINK-37109][state] Improve state processor API key iteration speed [flink]

2025-02-11 Thread via GitHub
flinkbot commented on PR #26145: URL: https://github.com/apache/flink/pull/26145#issuecomment-2651252345 ## CI report: * 569baee024b13aa0956f659f25a7861be5823649 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37269][table] Add new DESCRIPTOR type [flink]

2025-02-11 Thread via GitHub
flinkbot commented on PR #26144: URL: https://github.com/apache/flink/pull/26144#issuecomment-2651251992 ## CI report: * 39007934cf9352c558b10454492dadfa3c29da06 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] Add Flink 1.19.2 release [flink-web]

2025-02-11 Thread via GitHub
ferenc-csaky commented on code in PR #771: URL: https://github.com/apache/flink-web/pull/771#discussion_r195992 ## docs/content/posts/2025-02-TBD-release-1.19.2.md: ## @@ -0,0 +1,212 @@ +--- +title: "Apache Flink 1.19.2 Release Announcement" +date: "2025-02-TBDT00:00:00.000

Re: [PR] [FLINK-37005][table] Make StreamExecDeduplicate ouput insert only where possible [flink]

2025-02-11 Thread via GitHub
pnowojski commented on code in PR #26051: URL: https://github.com/apache/flink/pull/26051#discussion_r1951073995 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecDeduplicate.java: ## @@ -339,25 +362,39 @@ OneInputSt

Re: [PR] [FLINK-37005][table] Make StreamExecDeduplicate ouput insert only where possible [flink]

2025-02-11 Thread via GitHub
pnowojski commented on PR #26051: URL: https://github.com/apache/flink/pull/26051#issuecomment-2651197059 > check the changelog mode is not I when enabling mini-batch or keeping last row I think they are covered by the existing cases. For example `org.apache.flink.table.planner.plan.

[PR] [FLINK-37109][state] Improve state processor API key iteration speed [flink]

2025-02-11 Thread via GitHub
gaborgsomogyi opened a new pull request, #26145: URL: https://github.com/apache/flink/pull/26145 ## What is the purpose of the change This is backport of https://github.com/apache/flink/pull/26134. State processor API with RocksDB is extremely slow because it does the following

[jira] [Updated] (FLINK-37269) Add new DESCRIPTOR data type

2025-02-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37269: --- Labels: pull-request-available (was: ) > Add new DESCRIPTOR data type > --

[PR] [FLINK-37269][table] Add new DESCRIPTOR type [flink]

2025-02-11 Thread via GitHub
twalthr opened a new pull request, #26144: URL: https://github.com/apache/flink/pull/26144 ## What is the purpose of the change Adds the DESCRIPTOR type to the Flink type system. The DESCRIPTOR type is defined by the SQL standard and necessary for passing a list of column names into

[jira] [Closed] (FLINK-37219) Support value state in PTFs

2025-02-11 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37219. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 24f18975c7205ec3b58e2fb8dca048fa2b6

Re: [PR] [FLINK-37219][table] Support value state in PTFs [flink]

2025-02-11 Thread via GitHub
twalthr merged PR #26133: URL: https://github.com/apache/flink/pull/26133 -- 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.apach

Re: [PR] [hotfix] Integrate hive connector docs [flink]

2025-02-11 Thread via GitHub
snuyanzin commented on PR #26135: URL: https://github.com/apache/flink/pull/26135#issuecomment-2651069835 @afedulov since you are a release manager for 1.20 I'd like to double. check with you whether it is ok to merge it now or better wait till release finished -- This is an automated

[jira] [Resolved] (FLINK-37150) Adjust the documentation of the configuration file to remove the support for the old configuration file.

2025-02-11 Thread Junrui Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37150. Fix Version/s: 2.0.0 Resolution: Done master: * 9ea618243727d3297ec66f88bbde89e579d4ed3b

Re: [PR] [BP-2.0][FLINK-37150][doc] Update flink configuration file documentation. [flink]

2025-02-11 Thread via GitHub
JunRuiLee merged PR #26141: URL: https://github.com/apache/flink/pull/26141 -- 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-37298) Custom Batch Handling in AsyncSink

2025-02-11 Thread Poorvank Bhatia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926015#comment-17926015 ] Poorvank Bhatia commented on FLINK-37298: - Thanks [~chalixar] . I have modified

[jira] [Created] (FLINK-37302) Support timers in PTFs

2025-02-11 Thread Timo Walther (Jira)
Timo Walther created FLINK-37302: Summary: Support timers in PTFs Key: FLINK-37302 URL: https://issues.apache.org/jira/browse/FLINK-37302 Project: Flink Issue Type: Sub-task Compone

[jira] [Commented] (FLINK-37298) Custom Batch Handling in AsyncSink

2025-02-11 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926004#comment-17926004 ] Ahmed Hamdy commented on FLINK-37298: - Thanks [~poorvank] , yes If you could format

Re: [PR] [FLINK-37093][table] Fix catalog that failed validation due to no type still exists in catalogStoreHolder [flink]

2025-02-11 Thread via GitHub
jiefei30 commented on PR #25946: URL: https://github.com/apache/flink/pull/25946#issuecomment-2650914882 > > need I backport this fix to release-2.0 ? @hackergin @fsk119 > > Please help backport to 2.0 and 1.20. I think 1.19 can also be fixed. done. #26138 #26141 @hackergin -

Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc]

2025-02-11 Thread via GitHub
beryllw commented on PR #3856: URL: https://github.com/apache/flink-cdc/pull/3856#issuecomment-2650803019 CI https://github.com/beryllw/flink-cdc/actions/runs/13263762804 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS

2025-02-11 Thread Boris Litvak (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925997#comment-17925997 ] Boris Litvak commented on FLINK-28171: -- [~aliazov] [~elishamoshe]  There has been

Re: [PR] [FLINK-37120][pipeline-connector/mysql] Add ending split chunk first to avoid TaskManager oom [flink-cdc]

2025-02-11 Thread via GitHub
beryllw commented on PR #3856: URL: https://github.com/apache/flink-cdc/pull/3856#issuecomment-2650818395 CI https://github.com/beryllw/flink-cdc/actions/runs/1326383. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

Re: [PR] [FLINK-37275][pipeline-connector/mysql] MySQL source connector supports using the base module's source metric statistics [flink-cdc]

2025-02-11 Thread via GitHub
beryllw commented on PR #3914: URL: https://github.com/apache/flink-cdc/pull/3914#issuecomment-2650816720 > CI. https://github.com/beryllw/flink-cdc/actions/runs/13260216008 @leonardBang Please help me retrigger the CI. -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat

2025-02-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37301: --- Labels: pull-request-available (was: ) > Fix wrong flag returned by ForStStateBackend#suppo

[jira] [Assigned] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37300: -- Assignee: He Wang > Add database native type information to Column struct to generate ddl >

Re: [PR] [FLINK-37301][state/forst] Fix wrong flag returned by `ForStStateBackend#supportsSavepointFormat` [flink]

2025-02-11 Thread via GitHub
flinkbot commented on PR #26143: URL: https://github.com/apache/flink/pull/26143#issuecomment-2650723443 ## CI report: * 5d1d4727f48cb73401e8edc4f392f56a8a183cfa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-36564) Running CI in random timezone to expose more time related bugs

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925979#comment-17925979 ] Leonard Xu edited comment on FLINK-36564 at 2/11/25 12:27 PM:

[jira] [Resolved] (FLINK-36564) Running CI in random timezone to expose more time related bugs

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36564. Resolution: Fixed Fixed via master: b44e5708b84e2de8bd9dc6e5e1e7d5b5bf1926e8 > Running CI in rand

Re: [PR] [FLINK-36945] MySQL CDC supports parsing RENAME TABLE Statement with multiple tables [flink-cdc]

2025-02-11 Thread via GitHub
leonardBang merged PR #3876: URL: https://github.com/apache/flink-cdc/pull/3876 -- 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-37119] Bump the version of Paimon flink to 1.0.0. [flink-cdc]

2025-02-11 Thread via GitHub
lvyanquan commented on code in PR #3857: URL: https://github.com/apache/flink-cdc/pull/3857#discussion_r1950776026 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/pom.xml: ## @@ -29,7 +29,7 @@ limitations under the License. flink-cdc-p

[PR] [FLINK-37301][state/forst] Fix wrong flag returned by `ForStStateBackend#supportsSavepointFormat` [flink]

2025-02-11 Thread via GitHub
Zakelly opened a new pull request, #26143: URL: https://github.com/apache/flink/pull/26143 ## What is the purpose of the change The `ForStStateBackend` did not override the `supportsSavepointFormat`, which means it gives the wrong flag. We should fix this. ## Brief change l

[jira] [Resolved] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37262. Resolution: Fixed Fixed via master: 0a4c256433c60b8a43ccc412d38f35904d0b5448 > MySQL CDC connecto

[jira] [Resolved] (FLINK-36564) Running CI in random timezone to expose more time related bugs

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36564. Resolution: Resolved > Running CI in random timezone to expose more time related bugs > -

[jira] [Reopened] (FLINK-36564) Running CI in random timezone to expose more time related bugs

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-36564: > Running CI in random timezone to expose more time related bugs > --

[jira] [Assigned] (FLINK-36564) Running CI in random timezone to expose more time related bugs

2025-02-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36564: -- Assignee: Yanquan Lv > Running CI in random timezone to expose more time related bugs >

Re: [PR] [FLINK-36564][ci] Running CI in random timezone to expose more time related bugs. [flink-cdc]

2025-02-11 Thread via GitHub
leonardBang merged PR #3650: URL: https://github.com/apache/flink-cdc/pull/3650 -- 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

  1   2   >