[jira] [Assigned] (FLINK-37068) Cross-team verification for FLIP-473

2025-01-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37068: Assignee: (was: xuyang) > Cross-team verification for FLIP-473 >

[PR] [FLINK-37076][table-planner] Support PTFs until ExecNode level [flink]

2025-01-19 Thread via GitHub
twalthr opened a new pull request, #26019: URL: https://github.com/apache/flink/pull/26019 ## What is the purpose of the change This implements a first skeleton for integrating PTFs into the planner. The PR prepares the code base for implementing a corresponding StreamExecNode.

[jira] [Commented] (FLINK-37068) Cross-team verification for FLIP-473

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914575#comment-17914575 ] xuyang commented on FLINK-37068: Currently, FLIP-473 introduces the implementation of si

Re: [PR] [hotfix] Miscellaneous fixes on GHA workflows [flink-cdc]

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

[jira] [Closed] (FLINK-37172) Add logs in all existing async state ops to check if they are under async state when running

2025-01-19 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-37172. --- Assignee: xuyang Resolution: Fixed Fixed in master: 4a5238c020961efaa8f84dc1f414aa69fec49e32

[PR] [FLINK-37126] Add Validator for Autoscaler [flink-kubernetes-operator]

2025-01-19 Thread via GitHub
huyuanfeng2018 opened a new pull request, #936: URL: https://github.com/apache/flink-kubernetes-operator/pull/936 ## What is the purpose of the change Add Validator for Autoscler, Facilitates StandaloneAutoscaler to detect configuration anomalies in advance ## Brief cha

Re: [PR] [FLINK-37126] Add Validator for Autoscler [flink-kubernetes-operator]

2025-01-19 Thread via GitHub
huyuanfeng2018 closed pull request #935: [FLINK-37126] Add Validator for Autoscler URL: https://github.com/apache/flink-kubernetes-operator/pull/935 -- 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 t

Re: [PR] [FLINK-37172][table-runtime] Add logs in all existing async state ops to check if they are under async state when running [flink]

2025-01-19 Thread via GitHub
lincoln-lil merged PR #26014: URL: https://github.com/apache/flink/pull/26014 -- 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.a

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

2025-01-19 Thread via GitHub
beryllw commented on PR #3856: URL: https://github.com/apache/flink-cdc/pull/3856#issuecomment-2601540924 > I think adding a test in [MySqlSourceITCase](https://github.com/apache/flink-cdc/blob/8815f2b879fd48ad6211141b7f627eb1d143a02c/flink-cdc-connect/flink-cdc-source-connectors/flink-conne

Re: [PR] [hotfix] Miscellaneous fixes on GHA workflows [flink-cdc]

2025-01-19 Thread via GitHub
yuxiqian commented on PR #3839: URL: https://github.com/apache/flink-cdc/pull/3839#issuecomment-2601534578 CI failure seems irrelevant to this change. -- 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

Re: [PR] [FLINK-37172][table-runtime] Add logs in all existing async state ops to check if they are under async state when running [flink]

2025-01-19 Thread via GitHub
xuyangzhong commented on PR #26014: URL: https://github.com/apache/flink/pull/26014#issuecomment-2601528274 All tests in table-planner and table-runtime module have been successfully. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[jira] [Updated] (FLINK-37126) Add Validator for Autoscler

2025-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37126: --- Labels: pull-request-available (was: ) > Add Validator for Autoscler >

Re: [PR] [FLINK-37172][table-runtime] Add logs in all existing async state ops to check if they are under async state when running [flink]

2025-01-19 Thread via GitHub
xuyangzhong commented on PR #26014: URL: https://github.com/apache/flink/pull/26014#issuecomment-2601522733 The ci failed caused by https://issues.apache.org/jira/browse/FLINK-37174 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[PR] [FLINK-37126] Add Validator for Autoscler [flink-kubernetes-operator]

2025-01-19 Thread via GitHub
huyuanfeng2018 opened a new pull request, #935: URL: https://github.com/apache/flink-kubernetes-operator/pull/935 ## What is the purpose of the change Add Validator for Autoscler, Facilitates StandaloneAutoscaler to detect configuration anomalies in advance ## Brief cha

Re: [PR] [FLINK-35490] Migrate tests to JUnit 5 and AssertJ [flink-cdc]

2025-01-19 Thread via GitHub
yuxiqian commented on PR #3742: URL: https://github.com/apache/flink-cdc/pull/3742#issuecomment-2601525774 Rebased and resolved conflicts again. Maybe we can work on this right after cutting branch to minimize the rebase chore. -- This is an automated message from the Apache Git Service.

Re: [PR] [FLINK-37174][sql-client] Fix failed tests about SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp [flink]

2025-01-19 Thread via GitHub
xuyangzhong commented on PR #26018: URL: https://github.com/apache/flink/pull/26018#issuecomment-2601511911 @xaniasd @dianfu the pr https://github.com/apache/flink/pull/25541 seems to break the ci, and this pr tries to fix it. Can you take a look at this one? -- This is an automated messa

[jira] [Updated] (FLINK-37174) SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp failed

2025-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37174: --- Labels: pull-request-available (was: ) > SqlClientTest#testPrintAllModeHelp and #testPrintE

[PR] [FLINK-37174][sql-client] Fix failed tests about SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp [flink]

2025-01-19 Thread via GitHub
xuyangzhong opened a new pull request, #26018: URL: https://github.com/apache/flink/pull/26018 ## What is the purpose of the change Fix failed tests about SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp ## Brief change log - *Fix failed tests about Sq

[jira] [Closed] (FLINK-37166) FlinkConfigManager version prefix logic not thread safe

2025-01-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-37166. -- Resolution: Fixed merged to main 4c2c90c16c351e558d2e0ed4655bf9a2654a96e4 > FlinkConfigManager versio

[jira] [Created] (FLINK-37174) SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp failed

2025-01-19 Thread xuyang (Jira)
xuyang created FLINK-37174: -- Summary: SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp failed Key: FLINK-37174 URL: https://issues.apache.org/jira/browse/FLINK-37174 Project: Flink

Re: [PR] [FLINK-37166] Use concurrenthashmap in flink config manager [flink-kubernetes-operator]

2025-01-19 Thread via GitHub
gyfora merged PR #933: URL: https://github.com/apache/flink-kubernetes-operator/pull/933 -- 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

Re: [PR] [FLINK-37133][table] Support Submitting Refresh Job of Materialized Table to Yarn/K8s [flink]

2025-01-19 Thread via GitHub
hackergin commented on PR #25988: URL: https://github.com/apache/flink/pull/25988#issuecomment-2601499341 @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-37021][state/forst] Implement fast cp/restore for ForSt StateBackend with Strategy EveryTime [flink]

2025-01-19 Thread via GitHub
flinkbot commented on PR #26017: URL: https://github.com/apache/flink/pull/26017#issuecomment-2601478871 ## CI report: * 0d8b60d4cc4c1534d11ed4f27ed403da87bc4d90 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37021][state/forst] Implement fast cp/restore for ForSt StateBackend with Strategy EveryTime [flink]

2025-01-19 Thread via GitHub
Zakelly commented on PR #26017: URL: https://github.com/apache/flink/pull/26017#issuecomment-2601472405 @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-37133][table] Support Submitting Refresh Job of Materialized Table to Yarn/K8s [flink]

2025-01-19 Thread via GitHub
hackergin commented on PR #25988: URL: https://github.com/apache/flink/pull/25988#issuecomment-2601472272 test_ci connect failed because : https://issues.apache.org/jira/browse/FLINK-36290 test_ci table failed because : https://issues.apache.org/jira/browse/FLINK-36167 -- This is an

Re: [PR] [FLINK-37021][state/forst] Implement fast cp/restore for ForSt StateBackend [flink]

2025-01-19 Thread via GitHub
Zakelly commented on PR #25924: URL: https://github.com/apache/flink/pull/25924#issuecomment-2601472212 @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-36663][Window]Fix the first processWatermark has extra data after restore by restore timeService's watermark. [flink]

2025-01-19 Thread via GitHub
xing1mo commented on PR #25637: URL: https://github.com/apache/flink/pull/25637#issuecomment-2601440591 @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-36167][Table] Fix unstable tests in TableSinkITCase [flink]

2025-01-19 Thread via GitHub
xishuaidelin closed pull request #26015: [FLINK-36167][Table] Fix unstable tests in TableSinkITCase URL: https://github.com/apache/flink/pull/26015 -- 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-36167][Table] Fix unstable tests in TableSinkITCase [flink]

2025-01-19 Thread via GitHub
xishuaidelin commented on PR #26015: URL: https://github.com/apache/flink/pull/26015#issuecomment-2601438665 > Hi, @xishuaidelin is this bug same with #25892? It looks like we're both trying to address the same problem. I would close this pr and review #25892. :) -- This is an aut

[jira] [Closed] (FLINK-37168) TimerRegistrationAction in unregisteredTimers is not cleaned up properly after the timers are registered

2025-01-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-37168. --- Fix Version/s: 2.0.0 1.19.2 1.20.1 Resolution: Fixed Merged to:

[jira] [Updated] (FLINK-37168) TimerRegistrationAction in unregisteredTimers is not cleaned up properly after the timers are registered

2025-01-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-37168: Affects Version/s: 1.19.2 1.20.1 > TimerRegistrationAction in unregisteredTimers is

Re: [PR] [FLINK-37168][python] clean up TimerRegistrationAction in unregisteredTimers list after timers are registered [flink]

2025-01-19 Thread via GitHub
dianfu merged PR #26011: URL: https://github.com/apache/flink/pull/26011 -- 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

Re: [PR] [FLINK-37168][python] clean up TimerRegistrationAction in unregisteredTimers list after timers are registered [flink]

2025-01-19 Thread via GitHub
dianfu commented on code in PR #26011: URL: https://github.com/apache/flink/pull/26011#discussion_r1921819843 ## flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/process/timer/TimerRegistrationAction.java: ## @@ -26,17 +29,33 @@ public class TimerRegist

Re: [PR] [FLINK-37168][python] clean up TimerRegistrationAction in unregisteredTimers list after timers are registered [flink]

2025-01-19 Thread via GitHub
dianfu commented on code in PR #26011: URL: https://github.com/apache/flink/pull/26011#discussion_r1921819843 ## flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/process/timer/TimerRegistrationAction.java: ## @@ -26,17 +29,33 @@ public class TimerRegist

[jira] [Updated] (FLINK-37168) TimerRegistrationAction in unregisteredTimers is not cleaned up properly after the timers are registered

2025-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37168: --- Labels: pull-request-available (was: ) > TimerRegistrationAction in unregisteredTimers is n

Re: [PR] [FLINK-36167][Table] Fix unstable tests in TableSinkITCase [flink]

2025-01-19 Thread via GitHub
flinkbot commented on PR #26015: URL: https://github.com/apache/flink/pull/26015#issuecomment-2601368625 ## CI report: * 35fa9721546377e4abf8332c9428f0a9b623c601 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-37168) TimerRegistrationAction in unregisteredTimers is not cleaned up properly after the timers are registered

2025-01-19 Thread Shuyi Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-37168: --- Description: 2 main issues: - TimerRegistrationAction in unregisteredTimers are not cleared for proc

Re: [PR] [FLINK-37173][build] Fix license check issue in JDK11 build [flink]

2025-01-19 Thread via GitHub
flinkbot commented on PR #26016: URL: https://github.com/apache/flink/pull/26016#issuecomment-2601369710 ## CI report: * 75124ba8c43733c3addfe7b3e360bb109e264206 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37172][table-runtime] Add logs in all existing async state ops to check if they are under async state when running [flink]

2025-01-19 Thread via GitHub
flinkbot commented on PR #26014: URL: https://github.com/apache/flink/pull/26014#issuecomment-2601367798 ## CI report: * 0cef14d6fe5ea501708d5575b3fdb678bd3cdda5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37162] Add sinks.md to describe Flink's Data Sink API. [flink]

2025-01-19 Thread via GitHub
flinkbot commented on PR #26013: URL: https://github.com/apache/flink/pull/26013#issuecomment-2601367008 ## CI report: * 932dc27e123116104dd41101499a1f8af33038a9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37021][state/forst] Implement fast cp/restore for ForSt StateBackend with Strategy EveryTime [flink]

2025-01-19 Thread via GitHub
Zakelly commented on PR #26017: URL: https://github.com/apache/flink/pull/26017#issuecomment-2601358426 @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-37021][state/forst] Implement fast cp/restore for ForSt StateBackend with Strategy EveryTime [flink]

2025-01-19 Thread via GitHub
AlexYinHan commented on PR #26017: URL: https://github.com/apache/flink/pull/26017#issuecomment-2601315772 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

[PR] [FLINK-37021][state/forst] Implement fast cp/restore for ForSt StateBackend with Strategy EveryTime [flink]

2025-01-19 Thread via GitHub
AlexYinHan opened a new pull request, #26017: URL: https://github.com/apache/flink/pull/26017 ## What is the purpose of the change This PR implements fast snapshot/restore for ForSt. Specifically, it implements different strategies for ```ForStStateDataTransfer```, so that For

Re: [PR] [FLINK-34495][e2e] Enable incremental checkpoint for stop-with-savepoint tests [flink]

2025-01-19 Thread via GitHub
Zakelly closed pull request #24376: [FLINK-34495][e2e] Enable incremental checkpoint for stop-with-savepoint tests URL: https://github.com/apache/flink/pull/24376 -- 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] [DRAFT] Declare async state processing [flink]

2025-01-19 Thread via GitHub
Zakelly closed pull request #24719: [DRAFT] Declare async state processing URL: https://github.com/apache/flink/pull/24719 -- 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-37021][state/forst] Implement fast cp/restore for ForSt StateBackend [flink]

2025-01-19 Thread via GitHub
Zakelly commented on PR #25924: URL: https://github.com/apache/flink/pull/25924#issuecomment-2601286007 @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-37021][state/forst] Implement fast cp/restore for ForSt StateBackend [flink]

2025-01-19 Thread via GitHub
Zakelly commented on PR #25924: URL: https://github.com/apache/flink/pull/25924#issuecomment-2601285910 CI is not triggering -- 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 comme

Re: [PR] [FLINK-36167][Table] Fix unstable tests in TableSinkITCase [flink]

2025-01-19 Thread via GitHub
xuyangzhong commented on PR #26015: URL: https://github.com/apache/flink/pull/26015#issuecomment-2601283060 Hi, @xishuaidelin is this bug same with https://github.com/apache/flink/pull/25892? -- This is an automated message from the Apache Git Service. To respond to the message, please lo

Re: [PR] [FLINK-37133][table] Support Submitting Refresh Job of Materialized Table to Yarn/K8s [flink]

2025-01-19 Thread via GitHub
hackergin commented on PR #25988: URL: https://github.com/apache/flink/pull/25988#issuecomment-2601282166 @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-37173) Failed to pass license check in JDK11 build

2025-01-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37173: --- Description: {code:java} 00:57:16,804 INFO org.apache.flink.tools.ci.licensecheck.NoticeFileChecker

Re: [PR] [FLINK-36167][Table] Fix unstable tests in TableSinkITCase [flink]

2025-01-19 Thread via GitHub
xishuaidelin commented on PR #26015: URL: https://github.com/apache/flink/pull/26015#issuecomment-2601256414 1. The reason for the +U message is that among the 4 concurrent tasks, one task's initialization is delayed. During KeyedUpsertingSinkFunction#initializeState, the raw value of rawRe

[jira] [Updated] (FLINK-37173) Failed to pass license check in JDK11 build

2025-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37173: --- Labels: pull-request-available (was: ) > Failed to pass license check in JDK11 build >

[PR] [FLINK-37173][build] Fix license check issue in JDK11 build [flink]

2025-01-19 Thread via GitHub
reswqa opened a new pull request, #26016: URL: https://github.com/apache/flink/pull/26016 ## What is the purpose of the change *Fix license check issue in JDK11 build* ## Brief change log - *upgrade scala version in NOTICE file* ## Does this pull request

Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc]

2025-01-19 Thread via GitHub
yuxiqian commented on code in PR #3865: URL: https://github.com/apache/flink-cdc/pull/3865#discussion_r1921739476 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java: ## @@ -169,20 +173,52 @@ public static Schema getLeastCommonSchema(

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

2025-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36167: --- Labels: pull-request-available test-stability (was: test-stability) > testSinkDisorderChang

[PR] [FLINK-36167][Table] Fix unstable tests in TableSinkITCase [flink]

2025-01-19 Thread via GitHub
xishuaidelin opened a new pull request, #26015: URL: https://github.com/apache/flink/pull/26015 ## What is the purpose of the change This pull request mainly fix the unstable test failed in TableSinkITCase. ## Brief change log Fix initializeState process in K

Re: [PR] [FLINK-36594][hive]HiveCatalog should set HiveConf.hiveSiteLocation back [flink]

2025-01-19 Thread via GitHub
slankka commented on PR #25568: URL: https://github.com/apache/flink/pull/25568#issuecomment-2601240031 @tomncooper rebased and ci report SUCCESS -- 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 t

Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc]

2025-01-19 Thread via GitHub
yuxiqian commented on code in PR #3865: URL: https://github.com/apache/flink-cdc/pull/3865#discussion_r1921735422 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java: ## @@ -452,6 +455,43 @@ public static Schema inferWiderSchema(@Nullable Schema

Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc]

2025-01-19 Thread via GitHub
yuxiqian commented on code in PR #3865: URL: https://github.com/apache/flink-cdc/pull/3865#discussion_r1921735422 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java: ## @@ -452,6 +455,43 @@ public static Schema inferWiderSchema(@Nullable Schema

Re: [PR] [FLINK-37132][transform] validate meta schema in Multi Transform [flink-cdc]

2025-01-19 Thread via GitHub
yuxiqian commented on code in PR #3865: URL: https://github.com/apache/flink-cdc/pull/3865#discussion_r1921735422 ## flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java: ## @@ -452,6 +455,43 @@ public static Schema inferWiderSchema(@Nullable Schema

[jira] [Commented] (FLINK-37156) A Flink pipeline supports collecting data once and writing it to multiple sinks.

2025-01-19 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914529#comment-17914529 ] yux commented on FLINK-37156: - Hi Cheng, Thanks for reporting this! There are already some

Re: [PR] [FLINK-36594][hive]HiveCatalog should set HiveConf.hiveSiteLocation back [flink]

2025-01-19 Thread via GitHub
slankka commented on PR #25568: URL: https://github.com/apache/flink/pull/25568#issuecomment-2601224512 @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-37172) Add logs in all existing async state ops to check if they are under async state when running

2025-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37172: --- Labels: pull-request-available (was: ) > Add logs in all existing async state ops to check

[jira] [Updated] (FLINK-37173) Failed to pass license check in JDK11 build

2025-01-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37173: --- Description: 00:57:16,804 INFO org.apache.flink.tools.ci.licensecheck.NoticeFileChecker [] - Proble

[PR] [FLINK-37172][table-runtime] Add logs in all existing async state ops to check if they are under async state when running [flink]

2025-01-19 Thread via GitHub
xuyangzhong opened a new pull request, #26014: URL: https://github.com/apache/flink/pull/26014 ## What is the purpose of the change Add logs in all existing async state ops to check if they are under async state when running ## Brief change log - Add logs in all existi

[jira] [Created] (FLINK-37173) Failed to pass license check in JDK11 build

2025-01-19 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-37173: -- Summary: Failed to pass license check in JDK11 build Key: FLINK-37173 URL: https://issues.apache.org/jira/browse/FLINK-37173 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37172) Add logs in all existing async state ops to check if they are under async state when running

2025-01-19 Thread xuyang (Jira)
xuyang created FLINK-37172: -- Summary: Add logs in all existing async state ops to check if they are under async state when running Key: FLINK-37172 URL: https://issues.apache.org/jira/browse/FLINK-37172 Proj

Re: [PR] [FLINK-36594][hive]HiveCatalog should set HiveConf.hiveSiteLocation back [flink]

2025-01-19 Thread via GitHub
slankka commented on PR #25568: URL: https://github.com/apache/flink/pull/25568#issuecomment-2601215855 @tomncooper rebased my PR ,but CI still failed. -- 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 g

Re: [PR] [FLINK-37163] Add documents for recently merged PRs in FlinkCDC 3.3. [flink-cdc]

2025-01-19 Thread via GitHub
yuxiqian commented on code in PR #3872: URL: https://github.com/apache/flink-cdc/pull/3872#discussion_r1921725122 ## docs/content/docs/connectors/pipeline-connectors/overview.md: ## Review Comment: Ditto ## docs/content.zh/docs/connectors/pipeline-connectors/over

[jira] [Commented] (FLINK-37045) Expose state v2 creation APIs to datastream user

2025-01-19 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914523#comment-17914523 ] Zakelly Lan commented on FLINK-37045: - Follow-up commit 7964466016daea1f53bf14821c85

[jira] [Resolved] (FLINK-37028) Datastream Window operator with async state processing

2025-01-19 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37028. - Fix Version/s: 2.0.0 Resolution: Fixed > Datastream Window operator with async state proc

[jira] [Commented] (FLINK-37028) Datastream Window operator with async state processing

2025-01-19 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914522#comment-17914522 ] Zakelly Lan commented on FLINK-37028: - Merge into master via : ab791f9eb0c55134a25de

Re: [PR] [FLINK-37133][table] Support Submitting Refresh Job of Materialized Table to Yarn/K8s [flink]

2025-01-19 Thread via GitHub
hackergin commented on code in PR #25988: URL: https://github.com/apache/flink/pull/25988#discussion_r1921709924 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/application/ScriptExecutor.java: ## @@ -194,6 +194,7 @@ public boolean hasNext()

[jira] [Updated] (FLINK-37162) Add Data Sink Documentation

2025-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37162: --- Labels: 2.0-related pull-request-available (was: 2.0-related) > Add Data Sink Documentation

[jira] [Commented] (FLINK-37162) Add Data Sink Documentation

2025-01-19 Thread Yanquan Lv (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914521#comment-17914521 ] Yanquan Lv commented on FLINK-37162: I'm willing to take this. > Add Data Sink Docu

[PR] [FLINK-37162] Add sinks.md to describe Flink's Data Sink API. [flink]

2025-01-19 Thread via GitHub
lvyanquan opened a new pull request, #26013: URL: https://github.com/apache/flink/pull/26013 ## What is the purpose of the change Add doc for Sink API. ## Brief change log Add doc for Sink API and remove legacy doc about SourceFunction. ## Verifying thi

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

2025-01-19 Thread via GitHub
yuxiqian commented on code in PR #770: URL: https://github.com/apache/flink-web/pull/770#discussion_r1921708860 ## docs/content/posts/2025-01-18-release-cdc-3.3.0.md: ## @@ -0,0 +1,79 @@ +--- +title: "Apache Flink CDC 3.3.0 Release Announcement" +date: "2025-01-18T08:00:00.000Z

[jira] [Updated] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs"

2025-01-19 Thread Junrui Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37160: --- Description: In Flink 2.0, we support the capability of adaptive broadcast join for batch jobs, whi

Re: [PR] [FLINK-37133][table] Support Submitting Refresh Job of Materialized Table to Yarn/K8s [flink]

2025-01-19 Thread via GitHub
hackergin commented on code in PR #25988: URL: https://github.com/apache/flink/pull/25988#discussion_r1921707918 ## flink-table/flink-sql-gateway/src/test/resources/application/no_semicolon.q: ## @@ -0,0 +1,25 @@ +-- begin-statement-set.q - BEGIN STATEMENT SET, END +-- +-- Licen

[jira] [Updated] (FLINK-36578) Fixed inconsistent format when converting json type data to string

2025-01-19 Thread Lee SeungMin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee SeungMin updated FLINK-36578: - Issue Type: New Feature (was: Improvement) > Fixed inconsistent format when converting json ty

Re: [PR] [FLINK-37088][k8s]support flink applicaton taskmanager log mounting [flink]

2025-01-19 Thread via GitHub
baimafeima-yf commented on code in PR #25944: URL: https://github.com/apache/flink/pull/25944#discussion_r1921705143 ## flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java: ## @@ -510,6 +510,23 @@ public class KubernetesConfigOpt

[jira] [Updated] (FLINK-36578) Fixed inconsistent format when converting json type data to string

2025-01-19 Thread Lee SeungMin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee SeungMin updated FLINK-36578: - Issue Type: New Feature (was: Bug) > Fixed inconsistent format when converting json type data

[jira] [Updated] (FLINK-36578) Fixed inconsistent format when converting json type data to string

2025-01-19 Thread Lee SeungMin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee SeungMin updated FLINK-36578: - Issue Type: Improvement (was: New Feature) > Fixed inconsistent format when converting json ty

Re: [PR] [FLINK-37133][table] Support Submitting Refresh Job of Materialized Table to Yarn/K8s [flink]

2025-01-19 Thread via GitHub
lsyldliu commented on code in PR #25988: URL: https://github.com/apache/flink/pull/25988#discussion_r1921699761 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/application/ScriptExecutor.java: ## @@ -194,6 +194,7 @@ public boolean hasNext()

[jira] [Updated] (FLINK-35282) Bump apache beam version to between 2.54 and 2.61

2025-01-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-35282: Summary: Bump apache beam version to between 2.54 and 2.61 (was: PyFlink Support for Apache Beam > 2.49)

[jira] [Resolved] (FLINK-36476) Remove all deprecated methods under public APIs in table modules and adapt the related tests to make them pass

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang resolved FLINK-36476. Resolution: Resolved > Remove all deprecated methods under public APIs in table modules and adapt > the r

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

2025-01-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-35282. --- Resolution: Fixed Merged to master via 6b6a73ed1b593e8ebd4fafd21a485882da3143a9 > PyFlink Support for Apach

[jira] [Updated] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction`, `ScalarFunction` and `TableFunction`

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36505: --- Parent: FLINK-37171 Issue Type: Sub-task (was: Improvement) > Remove all deprecated methods in `Imp

Re: [PR] [FLINK-35282][python] Upgrade Apache Beam > 2.54 [flink]

2025-01-19 Thread via GitHub
dianfu merged PR #25541: URL: https://github.com/apache/flink/pull/25541 -- 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

Re: [PR] [FLINK-37133][table] Support Submitting Refresh Job of Materialized Table to Yarn/K8s [flink]

2025-01-19 Thread via GitHub
hackergin commented on code in PR #25988: URL: https://github.com/apache/flink/pull/25988#discussion_r1921700034 ## flink-end-to-end-tests/test-scripts/test_kubernetes_materialized_table.sh: ## @@ -0,0 +1,242 @@ +#!/usr/bin/env bash +# +# Licensed to the Apache Software Foundati

[jira] [Updated] (FLINK-37171) Clear all remaining deprecated methods under public APIs in table modules

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-37171: --- Description: This is a collection of incomplete subtasks for https://issues.apache.org/jira/browse/FLINK-364

[jira] [Updated] (FLINK-36498) Remove deprecated method `ResolvedCatalogBaseTable#getSchema`

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36498: --- Parent: (was: FLINK-36476) Issue Type: Improvement (was: Sub-task) > Remove deprecated method `

Re: [PR] [FLINK-37133][table] Support Submitting Refresh Job of Materialized Table to Yarn/K8s [flink]

2025-01-19 Thread via GitHub
hackergin commented on code in PR #25988: URL: https://github.com/apache/flink/pull/25988#discussion_r1921700034 ## flink-end-to-end-tests/test-scripts/test_kubernetes_materialized_table.sh: ## @@ -0,0 +1,242 @@ +#!/usr/bin/env bash +# +# Licensed to the Apache Software Foundati

[jira] [Updated] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema`

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36495: --- Parent: FLINK-37171 Issue Type: Sub-task (was: Improvement) > Remove deprecated method `CatalogBase

[jira] [Updated] (FLINK-36498) Remove deprecated method `ResolvedCatalogBaseTable#getSchema`

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36498: --- Parent: FLINK-37171 Issue Type: Sub-task (was: Improvement) > Remove deprecated method `ResolvedCat

[jira] [Updated] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction`, `ScalarFunction` and `TableFunction`

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36505: --- Parent: (was: FLINK-36476) Issue Type: Improvement (was: Sub-task) > Remove all deprecated meth

[jira] [Updated] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema`

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36495: --- Parent: (was: FLINK-36476) Issue Type: Improvement (was: Sub-task) > Remove deprecated method `

[jira] [Updated] (FLINK-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream`

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36488: --- Parent: FLINK-37171 Issue Type: Sub-task (was: Improvement) > Remove deprecated method `StreamTable

[jira] [Updated] (FLINK-36489) Remove deprecated method `StreamTableEnvironment#toRetractStream`

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36489: --- Parent: FLINK-37171 Issue Type: Sub-task (was: Improvement) > Remove deprecated method `StreamTable

[jira] [Updated] (FLINK-36489) Remove deprecated method `StreamTableEnvironment#toRetractStream`

2025-01-19 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36489: --- Parent: (was: FLINK-36476) Issue Type: Improvement (was: Sub-task) > Remove deprecated method `

  1   2   >