Re: [PR] [FLINK-37011] Improve get source field value by column name in PreTransformProcessor. [flink-cdc]

2025-01-07 Thread via GitHub
ChaomingZhangCN commented on PR #3836: URL: https://github.com/apache/flink-cdc/pull/3836#issuecomment-2576587988 @yuxiqian Please take a look. -- 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

Re: [PR] [hotfix] Remove duplicated code to improve performance [flink-cdc]

2025-01-07 Thread via GitHub
ChaomingZhangCN commented on PR #3840: URL: https://github.com/apache/flink-cdc/pull/3840#issuecomment-2576589112 @yuxiqian Please take a look~ -- 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

[jira] [Created] (FLINK-37029) Fix the materialized table docs of full mode cron expression

2025-01-07 Thread dalongliu (Jira)
dalongliu created FLINK-37029: - Summary: Fix the materialized table docs of full mode cron expression Key: FLINK-37029 URL: https://issues.apache.org/jira/browse/FLINK-37029 Project: Flink Issue

Re: [PR] [FLINK-36898][Table] Support SQL FLOOR and CEIL functions with NanoSecond and MicroSecond for TIMESTAMP_TLZ [flink]

2025-01-07 Thread via GitHub
hanyuzheng7 commented on code in PR #25897: URL: https://github.com/apache/flink/pull/25897#discussion_r1906337467 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java: ## @@ -588,34 +588,50 @@ private Stream ceilTest

[jira] [Updated] (FLINK-37041) [Release-2.0] Verify that no exclusions were erroneously added to the japicmp plugin

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37041: - Summary: [Release-2.0] Verify that no exclusions were erroneously added to the japicmp plugin

[jira] [Updated] (FLINK-37040) CLONE - [Release-1.20] Review and update documentation

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37040: - Labels: (was: pull-request-available) > CLONE - [Release-1.20] Review and update documentation

[jira] [Updated] (FLINK-37041) [Release-2.0] Verify that no exclusions were erroneously added to the japicmp plugin

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37041: - Affects Version/s: (was: 1.20.0) > [Release-2.0] Verify that no exclusions were erroneously

[jira] [Updated] (FLINK-37040) CLONE - [Release-1.20] Review and update documentation

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37040: - Reporter: Xintong Song (was: Weijie Guo) > CLONE - [Release-1.20] Review and update documentati

[jira] [Assigned] (FLINK-37040) CLONE - [Release-1.20] Review and update documentation

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37040: Assignee: (was: Rui Fan) > CLONE - [Release-1.20] Review and update documentation > -

[jira] [Updated] (FLINK-37033) [Release-2.0] Create a new version in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37033: - Component/s: Release System > [Release-2.0] Create a new version in JIRA > -

Re: [PR] [FLINK-36926][table] Introduce window join operator with async state api [flink]

2025-01-07 Thread via GitHub
xuyangzhong commented on code in PR #25815: URL: https://github.com/apache/flink/pull/25815#discussion_r1906533740 ## flink-runtime/src/test/java/org/apache/flink/streaming/util/KeyedTwoInputStreamOperatorTestHarness.java: ## @@ -64,8 +67,24 @@ public KeyedTwoInputStreamOperator

[jira] [Updated] (FLINK-37029) Fix the materialized table docs of full mode cron expression

2025-01-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37029: --- Labels: pull-request-available (was: ) > Fix the materialized table docs of full mode cron

[jira] [Assigned] (FLINK-37039) CLONE - [Release-1.20] Triage release-blocking issues in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37039: Assignee: (was: Weijie Guo) > CLONE - [Release-1.20] Triage release-blocking issues i

Re: [PR] [FLINK-36576][runtime] Improving amount-based data balancing distribution algorithm for DefaultVertexParallelismAndInputInfosDecider [flink]

2025-01-07 Thread via GitHub
noorall commented on code in PR #25552: URL: https://github.com/apache/flink/pull/25552#discussion_r1906546993 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/util/AggregatedBlockingInputInfo.java: ## @@ -125,6 +118,9 @@ private static long[] comp

Re: [PR] [FLINK-36978]Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. [flink-cdc]

2025-01-07 Thread via GitHub
leonardBang merged PR #3825: URL: https://github.com/apache/flink-cdc/pull/3825 -- 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-36926][table] Introduce window join operator with async state api [flink]

2025-01-07 Thread via GitHub
xuyangzhong commented on PR #25815: URL: https://github.com/apache/flink/pull/25815#issuecomment-2576901758 Hi, @davidradl I have updated this pr, could you please to take a look again if you have time? -- This is an automated message from the Apache Git Service. To respond to the message

[PR] [FLINK-37042][maxcompute-pipeline-connector] Rename maxcompute pipieline connector options with kebab-case [flink-cdc]

2025-01-07 Thread via GitHub
ChaomingZhangCN opened a new pull request, #3842: URL: https://github.com/apache/flink-cdc/pull/3842 See [FLINK-37042](https://issues.apache.org/jira/browse/FLINK-37042?focusedCommentId=17910939#comment-17910939) -- This is an automated message from the Apache Git Service. To respond to t

[jira] [Updated] (FLINK-37042) Unify option names using kebab-case in MaxComputeDataSinkOptions

2025-01-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37042: --- Labels: pull-request-available (was: ) > Unify option names using kebab-case in MaxComputeD

Re: [PR] [FLINK-37042][maxcompute-pipeline-connector] Rename maxcompute pipieline connector options with kebab-case [flink-cdc]

2025-01-07 Thread via GitHub
ChaomingZhangCN commented on PR #3842: URL: https://github.com/apache/flink-cdc/pull/3842#issuecomment-2576932439 @leonardBang Please take a look~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

Re: [PR] [FLINK-37014][doc] Fix examples in materialized table docs [flink]

2025-01-07 Thread via GitHub
jiefei30 commented on PR #25904: URL: https://github.com/apache/flink/pull/25904#issuecomment-2576956287 @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-36754][transform] when projection is empty or null, it is treated as an asterisk [flink-cdc]

2025-01-07 Thread via GitHub
yuxiqian commented on code in PR #3749: URL: https://github.com/apache/flink-cdc/pull/3749#discussion_r1906628133 ## flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java: ## @@ -72,16 +72,16 @@ public String getSourceTable() { retu

[jira] [Commented] (FLINK-37042) Unify option names using kebab-case in MaxComputeDataSinkOptions

2025-01-07 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910948#comment-17910948 ] Leonard Xu commented on FLINK-37042: [~mingo]Would you like to improve this ? > Uni

[jira] [Assigned] (FLINK-37042) Unify option names using kebab-case in MaxComputeDataSinkOptions

2025-01-07 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37042: -- Assignee: ChaomingZhang > Unify option names using kebab-case in MaxComputeDataSinkOptions >

Re: [PR] [FLINK-36620][cdc-dist] Add support for specifying the --flink-home command line parameter with an '=' character [flink-cdc]

2025-01-07 Thread via GitHub
yuxiqian commented on code in PR #3838: URL: https://github.com/apache/flink-cdc/pull/3838#discussion_r1906572824 ## flink-cdc-dist/src/main/flink-cdc-bin/bin/flink-cdc.sh: ## @@ -21,9 +21,20 @@ args=("$@") # Check if FLINK_HOME is set in command-line arguments by "--flink-home

[jira] [Created] (FLINK-37044) Support connectors and formats as plugins

2025-01-07 Thread Karan Makhija (Jira)
Karan Makhija created FLINK-37044: - Summary: Support connectors and formats as plugins Key: FLINK-37044 URL: https://issues.apache.org/jira/browse/FLINK-37044 Project: Flink Issue Type: Impro

Re: [PR] [FLINK-36610] MySQL CDC supports parsing gh-ost / pt-osc generated schema changes [flink-cdc]

2025-01-07 Thread via GitHub
yuxiqian commented on PR #3668: URL: https://github.com/apache/flink-cdc/pull/3668#issuecomment-2576521439 Thanks for @lvyanquan and @GOODBOY008's kindly review, addressed your comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-36941][docs] Update DATE_FORMAT Doc and Python Tests in 1.19 [flink]

2025-01-07 Thread via GitHub
yiyutian1 commented on code in PR #25873: URL: https://github.com/apache/flink/pull/25873#discussion_r1906203128 ## flink-python/pyflink/table/expressions.py: ## @@ -350,14 +350,21 @@ def temporal_overlaps(left_time_point, def date_format(timestamp, format) -> Expression:

Re: [PR] [FLINK-37014][doc] Fix examples in materialized table docs [flink]

2025-01-07 Thread via GitHub
lsyldliu commented on code in PR #25904: URL: https://github.com/apache/flink/pull/25904#discussion_r1906247714 ## docs/content.zh/docs/dev/table/materialized-table/statements.md: ## @@ -233,8 +233,8 @@ CREATE MATERIALIZED TABLE my_materialized_table_full 'format' = 'js

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

2025-01-07 Thread via GitHub
leonardBang commented on PR #3839: URL: https://github.com/apache/flink-cdc/pull/3839#issuecomment-2576685883 Thanks @yuxiqian for considering the newly-added maxcompute label, nice work -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

Re: [PR] [FLINK-36486] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.registerDataStream from flink-table-api-java-bridge module [flink]

2025-01-07 Thread via GitHub
sn-12-3 commented on PR #25527: URL: https://github.com/apache/flink/pull/25527#issuecomment-2576712408 @xuyangzhong , Thanks for the review. I have now removed the `registerDataStream` from the Scala StreamTableEnvironment. Could you please have a look at it. -- This is an automated mes

[jira] [Created] (FLINK-37032) Prepare Flink 2.0 Release

2025-01-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-37032: Summary: Prepare Flink 2.0 Release Key: FLINK-37032 URL: https://issues.apache.org/jira/browse/FLINK-37032 Project: Flink Issue Type: New Feature C

[jira] [Updated] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown

2025-01-07 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37031: --- Description: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=64956&view=logs&

[jira] [Updated] (FLINK-37032) Prepare Flink 2.0 Release

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37032: - Reporter: Xintong Song (was: Weijie Guo) > Prepare Flink 2.0 Release >

[jira] [Updated] (FLINK-37032) Prepare Flink 2.0 Release

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37032: - Affects Version/s: (was: 1.20.0) > Prepare Flink 2.0 Release > - > >

[jira] [Commented] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown

2025-01-07 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910933#comment-17910933 ] Weijie Guo commented on FLINK-37031: Another exception is: {code:java} Jan 07 12:

[jira] [Assigned] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown

2025-01-07 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-37031: --- Assignee: Yanfei Lei > Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown >

[jira] [Commented] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown

2025-01-07 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910935#comment-17910935 ] Zakelly Lan commented on FLINK-37031: - [~Yanfei Lei] would you please take a look? t

[jira] [Updated] (FLINK-37033) [Release-2.0] Create a new version in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37033: - Summary: [Release-2.0] Create a new version in JIRA (was: CLONE - [Release-1.20] Create a new v

[jira] [Assigned] (FLINK-37032) Prepare Flink 2.0 Release

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37032: Assignee: Xintong Song (was: Weijie Guo) > Prepare Flink 2.0 Release > -

[jira] [Updated] (FLINK-37033) [Release-2.0] Create a new version in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37033: - Reporter: Xintong Song (was: Weijie Guo) > [Release-2.0] Create a new version in JIRA > ---

[jira] [Assigned] (FLINK-37033) [Release-2.0] Create a new version in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37033: Assignee: Xintong Song (was: Weijie Guo) > [Release-2.0] Create a new version in JIRA >

[jira] [Updated] (FLINK-37033) [Release-2.0] Create a new version in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37033: - Description: When contributors resolve an issue in JIRA, they are tagging it with a release tha

[jira] [Assigned] (FLINK-37034) [Release-2.0] Select executing Release Manager

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37034: Assignee: (was: Weijie Guo) > [Release-2.0] Select executing Release Manager > -

[jira] [Updated] (FLINK-37034) [Release-2.0] Select executing Release Manager

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37034: - Summary: [Release-2.0] Select executing Release Manager (was: CLONE - [Release-1.20] Select e

[jira] [Commented] (FLINK-36252) AsyncWaitOperatorTest.testProcessingTimeUnorderedWithRetry failed on AZP

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

[jira] [Updated] (FLINK-37034) [Release-2.0] Select executing Release Manager

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37034: - Reporter: Xintong Song (was: Weijie Guo) > [Release-2.0] Select executing Release Manager > --

[jira] [Closed] (FLINK-37033) [Release-2.0] Create a new version in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-37033. Resolution: Done Version 2.1.0 is created on JIRA > [Release-2.0] Create a new version in JIRA >

[jira] [Comment Edited] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown

2025-01-07 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910933#comment-17910933 ] Weijie Guo edited comment on FLINK-37031 at 1/8/25 5:50 AM:

[jira] [Created] (FLINK-37041) CLONE - [Release-1.20] Verify that no exclusions were erroneously added to the japicmp plugin

2025-01-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-37041: Summary: CLONE - [Release-1.20] Verify that no exclusions were erroneously added to the japicmp plugin Key: FLINK-37041 URL: https://issues.apache.org/jira/browse/FLINK-37041

[jira] [Updated] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown

2025-01-07 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37031: --- Description: {code:java} Jan 07 12:53:04 # Core dump will be written. Default location: /__w/3/s/fl

[jira] [Created] (FLINK-37034) CLONE - [Release-1.20] Select executing Release Manager

2025-01-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-37034: Summary: CLONE - [Release-1.20] Select executing Release Manager Key: FLINK-37034 URL: https://issues.apache.org/jira/browse/FLINK-37034 Project: Flink Issu

[jira] [Created] (FLINK-37039) CLONE - [Release-1.20] Triage release-blocking issues in JIRA

2025-01-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-37039: Summary: CLONE - [Release-1.20] Triage release-blocking issues in JIRA Key: FLINK-37039 URL: https://issues.apache.org/jira/browse/FLINK-37039 Project: Flink

[jira] [Created] (FLINK-37033) CLONE - [Release-1.20] Create a new version in JIRA

2025-01-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-37033: Summary: CLONE - [Release-1.20] Create a new version in JIRA Key: FLINK-37033 URL: https://issues.apache.org/jira/browse/FLINK-37033 Project: Flink Issue Typ

[jira] [Comment Edited] (FLINK-37033) [Release-2.0] Create a new version in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910934#comment-17910934 ] Xintong Song edited comment on FLINK-37033 at 1/8/25 5:51 AM:

[jira] [Updated] (FLINK-37034) [Release-2.0] Select executing Release Manager

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37034: - Fix Version/s: 2.0.0 (was: 1.20.0) > [Release-2.0] Select executing Rele

[jira] [Updated] (FLINK-37032) Prepare Flink 2.0 Release

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37032: - Fix Version/s: 2.0.0 (was: 1.20.0) > Prepare Flink 2.0 Release >

[jira] [Updated] (FLINK-37034) [Release-2.0] Select executing Release Manager

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37034: - Affects Version/s: (was: 1.20.0) > [Release-2.0] Select executing Release Manager > ---

[jira] [Updated] (FLINK-37033) [Release-2.0] Create a new version in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37033: - Fix Version/s: 2.0.0 > [Release-2.0] Create a new version in JIRA >

[jira] [Updated] (FLINK-37035) [Release-2.0] Create a release branch

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37035: - Summary: [Release-2.0] Create a release branch (was: CLONE - [Release-1.20] Create a release

[jira] [Updated] (FLINK-37035) [Release-2.0] Create a release branch

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37035: - Reporter: Xintong Song (was: Weijie Guo) > [Release-2.0] Create a release branch > ---

[jira] [Updated] (FLINK-37035) [Release-2.0] Create a release branch

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37035: - Fix Version/s: 2.0.0 (was: 1.20.0) > [Release-2.0] Create a release bran

[jira] [Updated] (FLINK-37034) [Release-2.0] Select executing Release Manager

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37034: - Fix Version/s: 2.0.0 > [Release-2.0] Select executing Release Manager > ---

Re: [PR] [FLINK-36832] Remove Deprecated class and relevant tests. [flink-connector-kafka]

2025-01-07 Thread via GitHub
lvyanquan closed pull request #144: [FLINK-36832] Remove Deprecated class and relevant tests. URL: https://github.com/apache/flink-connector-kafka/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

[jira] [Assigned] (FLINK-37035) [Release-2.0] Create a release branch

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37035: Assignee: Xintong Song (was: Weijie Guo) > [Release-2.0] Create a release branch >

[jira] [Updated] (FLINK-37035) [Release-2.0] Create a release branch

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37035: - Component/s: Release System > [Release-2.0] Create a release branch > -

[jira] [Updated] (FLINK-37035) [Release-2.0] Create a release branch

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37035: - Affects Version/s: (was: 1.20.0) > [Release-2.0] Create a release branch >

[jira] [Updated] (FLINK-37035) [Release-2.0] Create a release branch

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37035: - Labels: (was: pull-request-available) > [Release-2.0] Create a release branch > -

[jira] [Updated] (FLINK-37036) [Release-2.0] Prepare RC0 release

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37036: - Affects Version/s: (was: 1.20.0) > [Release-2.0] Prepare RC0 release > -

[jira] [Updated] (FLINK-37036) [Release-2.0] Prepare RC0 release

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37036: - Reporter: Xintong Song (was: Weijie Guo) > [Release-2.0] Prepare RC0 release >

[jira] [Assigned] (FLINK-37036) [Release-2.0] Prepare RC0 release

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37036: Assignee: (was: Weijie Guo) > [Release-2.0] Prepare RC0 release > ---

[jira] [Assigned] (FLINK-37037) [Release-2.0] Review Release Notes in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37037: Assignee: (was: Weijie Guo) > [Release-2.0] Review Release Notes in JIRA > --

[jira] [Updated] (FLINK-37037) [Release-2.0] Review Release Notes in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37037: - Affects Version/s: (was: 1.20.0) > [Release-2.0] Review Release Notes in JIRA >

[jira] [Updated] (FLINK-37037) [Release-2.0] Review Release Notes in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37037: - Reporter: Xintong Song (was: Weijie Guo) > [Release-2.0] Review Release Notes in JIRA > ---

[jira] [Updated] (FLINK-37037) [Release-2.0] Review Release Notes in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37037: - Fix Version/s: 2.0.0 (was: 1.20.0) > [Release-2.0] Review Release Notes i

[jira] [Updated] (FLINK-37038) CLONE - [Release-1.20] Cross team testing

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37038: - Affects Version/s: (was: 1.20.0) > CLONE - [Release-1.20] Cross team testing > -

[jira] [Updated] (FLINK-37038) CLONE - [Release-1.20] Cross team testing

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37038: - Reporter: Xintong Song (was: Weijie Guo) > CLONE - [Release-1.20] Cross team testing >

[jira] [Updated] (FLINK-37036) [Release-2.0] Prepare RC0 release

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37036: - Component/s: Release System > [Release-2.0] Prepare RC0 release > --

[jira] [Assigned] (FLINK-37038) CLONE - [Release-1.20] Cross team testing

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37038: Assignee: Xintong Song (was: Rui Fan) > CLONE - [Release-1.20] Cross team testing >

[jira] [Updated] (FLINK-37038) [Release-2.0] Cross team testing

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37038: - Summary: [Release-2.0] Cross team testing (was: CLONE - [Release-1.20] Cross team testing) > [

[jira] [Updated] (FLINK-37038) CLONE - [Release-1.20] Cross team testing

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37038: - Fix Version/s: 2.0.0 (was: 1.20.0) > CLONE - [Release-1.20] Cross team te

[jira] [Updated] (FLINK-37039) CLONE - [Release-1.20] Triage release-blocking issues in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37039: - Affects Version/s: (was: 1.20.0) > CLONE - [Release-1.20] Triage release-blocking issues in

[PR] [FLINK-37029][docs] Fix the materialized table docs of full mode cron expression [flink]

2025-01-07 Thread via GitHub
lsyldliu opened a new pull request, #25917: URL: https://github.com/apache/flink/pull/25917 ## What is the purpose of the change * Fix the materialized table docs* ## Brief change log - *Fix the materialized table docs* ## Verifying this change Thi

[jira] [Updated] (FLINK-37040) [Release-2.0] Review and update documentation

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37040: - Summary: [Release-2.0] Review and update documentation (was: CLONE - [Release-1.20] Review and

[jira] [Updated] (FLINK-37039) CLONE - [Release-1.20] Triage release-blocking issues in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37039: - Component/s: Release System > CLONE - [Release-1.20] Triage release-blocking issues in JIRA > --

[jira] [Updated] (FLINK-37039) CLONE - [Release-1.20] Triage release-blocking issues in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37039: - Reporter: Xintong Song (was: Weijie Guo) > CLONE - [Release-1.20] Triage release-blocking issue

[jira] [Updated] (FLINK-37040) CLONE - [Release-1.20] Review and update documentation

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37040: - Affects Version/s: (was: 1.20.0) > CLONE - [Release-1.20] Review and update documentation >

[jira] [Updated] (FLINK-37040) CLONE - [Release-1.20] Review and update documentation

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37040: - Fix Version/s: 2.0.0 (was: 1.20.0) (was: 2.0-previe

[jira] [Updated] (FLINK-37039) CLONE - [Release-1.20] Triage release-blocking issues in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37039: - Fix Version/s: 2.0.0 (was: 1.20.0) > CLONE - [Release-1.20] Triage releas

[jira] [Assigned] (FLINK-37041) [Release-2.0] Verify that no exclusions were erroneously added to the japicmp plugin

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-37041: Assignee: (was: Weijie Guo) > [Release-2.0] Verify that no exclusions were erroneous

[jira] [Updated] (FLINK-37039) [Release-2.0] Triage release-blocking issues in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37039: - Summary: [Release-2.0] Triage release-blocking issues in JIRA (was: CLONE - [Release-1.20] Tria

[jira] [Updated] (FLINK-37041) [Release-2.0] Verify that no exclusions were erroneously added to the japicmp plugin

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37041: - Fix Version/s: 2.0.0 > [Release-2.0] Verify that no exclusions were erroneously added to the >

[jira] [Updated] (FLINK-37041) [Release-2.0] Verify that no exclusions were erroneously added to the japicmp plugin

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37041: - Reporter: Xintong Song (was: Weijie Guo) > [Release-2.0] Verify that no exclusions were errone

[jira] [Updated] (FLINK-37036) [Release-2.0] Prepare RC0 release

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37036: - Fix Version/s: 2.0.0 (was: 1.20.0) > [Release-2.0] Prepare RC0 release >

[jira] [Updated] (FLINK-37036) [Release-2.0] Prepare RC0 release

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37036: - Summary: [Release-2.0] Prepare RC0 release (was: CLONE - [Release-1.20] Prepare RC0 release) >

[jira] [Updated] (FLINK-37034) [Release-2.0] Select executing Release Manager

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37034: - Fix Version/s: (was: 2.0.0) > [Release-2.0] Select executing Release Manager >

[jira] [Updated] (FLINK-37037) [Release-2.0] Review Release Notes in JIRA

2025-01-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-37037: - Summary: [Release-2.0] Review Release Notes in JIRA (was: CLONE - [Release-1.20] Review Release

Re: [PR] [FLINK-37029][docs] Fix the materialized table docs of full mode cron expression [flink]

2025-01-07 Thread via GitHub
flinkbot commented on PR #25917: URL: https://github.com/apache/flink/pull/25917#issuecomment-2576827432 ## CI report: * 7a531f092b53a82636f82a04abcd1aa2865fecab UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch pipeline sink support authentication [flink-cdc]

2025-01-07 Thread via GitHub
leonardBang commented on PR #3728: URL: https://github.com/apache/flink-cdc/pull/3728#issuecomment-2576910136 @beryllw sorry for late response, could you base the PR to latest master and then we can start the review? -- This is an automated message from the Apache Git Service. To respond

Re: [PR] [FLINK-36994][table] Support ALTER MATERIALIZED TABLE As statement [flink]

2025-01-07 Thread via GitHub
lsyldliu commented on code in PR #25880: URL: https://github.com/apache/flink/pull/25880#discussion_r1906542783 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterMaterializedTableAsQueryConverter.java: ## @@ -0,0 +1,160

Re: [PR] [FLINK-37042][maxcompute-pipeline-connector] Rename maxcompute pipieline connector options with kebab-case [flink-cdc]

2025-01-07 Thread via GitHub
leonardBang commented on PR #3842: URL: https://github.com/apache/flink-cdc/pull/3842#issuecomment-2576936732 @dingxin-tech Would you like to review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

<    1   2   3   4   >