Re: [PR] [FLINK-35599][cdc-connector][jdbc-mysql]Flink cdc pipeline sink jdbc mysql [flink-cdc]

2024-11-12 Thread via GitHub
lvyanquan commented on PR #3433: URL: https://github.com/apache/flink-cdc/pull/3433#issuecomment-2472706267 Thanks @kissycn for this great contribution, left some comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Updated] (FLINK-36685) Enable update/create operation on flinkdeployment resource in mutation webhook

2024-11-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36685: --- Labels: pull-request-available (was: ) > Enable update/create operation on flinkdeployment

Re: [PR] [FLINK-35599][cdc-connector][jdbc-mysql]Flink cdc pipeline sink jdbc mysql [flink-cdc]

2024-11-12 Thread via GitHub
lvyanquan commented on code in PR #3433: URL: https://github.com/apache/flink-cdc/pull/3433#discussion_r1839617689 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-jdbc/src/main/java/org/apache/flink/cdc/connectors/jdbc/config/JdbcPropertiesFormatter.java:

Re: [PR] [FLINK-35334][flink-table] Split constructor of generated code if it is too large. [flink]

2024-11-12 Thread via GitHub
littleeleventhwolf commented on PR #25644: URL: https://github.com/apache/flink/pull/25644#issuecomment-2472665263 @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

[jira] [Updated] (FLINK-36699) Fix nullability when converting cdc data type to flink data type

2024-11-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36699: --- Labels: pull-request-available (was: ) > Fix nullability when converting cdc data type to f

Re: [PR] [FLINK-25920] Ignore duplicate EOI in SinkWriter [1.20] [flink]

2024-11-12 Thread via GitHub
AHeise merged PR #25619: URL: https://github.com/apache/flink/pull/25619 -- 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

[PR] [FLINK-36685][Kubernetes Operator] allow CREATE/UPDATE operation on flinkdeployments resource on webhook mutation endpoint [flink-kubernetes-operator]

2024-11-12 Thread via GitHub
suez1224 opened a new pull request, #916: URL: https://github.com/apache/flink-kubernetes-operator/pull/916 ## What is the purpose of the change allow CREATE/UPDATE operation on flinkdeployments resource on webhook mutation endpoint ## Brief change log

[jira] [Assigned] (FLINK-36699) Fix nullability when converting cdc data type to flink data type

2024-11-12 Thread Ruan Hang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruan Hang reassigned FLINK-36699: - Assignee: Xiao Huang > Fix nullability when converting cdc data type to flink data type > -

[jira] [Created] (FLINK-36700) Elasticsearch pipeline sink support authentication

2024-11-12 Thread JunboWang (Jira)
JunboWang created FLINK-36700: - Summary: Elasticsearch pipeline sink support authentication Key: FLINK-36700 URL: https://issues.apache.org/jira/browse/FLINK-36700 Project: Flink Issue Type: Impr

[jira] [Assigned] (FLINK-36685) Enable update/create operation on flinkdeployment resource in mutation webhook

2024-11-12 Thread Shuyi Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-36685: -- Assignee: Shuyi Chen > Enable update/create operation on flinkdeployment resource in mutation

Re: [PR] [FLINK-35966][runtime] Introduce the TASKS for TaskManagerLoadBalanceMode enum [flink]

2024-11-12 Thread via GitHub
RocMarshal commented on PR #25647: URL: https://github.com/apache/flink/pull/25647#issuecomment-2472350285 hi, @zhuzhurk @1996fanrui Could you help take a look for the PR if you had the free time ? Many thanks ! -- This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-36065) Support for submitting StreamGraph

2024-11-12 Thread Ammu Parvathy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897809#comment-17897809 ] Ammu Parvathy commented on FLINK-36065: --- [~JunRuiLi] I assume that in this PR you

Re: [PR] [FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler [flink]

2024-11-12 Thread via GitHub
RocMarshal commented on code in PR #25504: URL: https://github.com/apache/flink/pull/25504#discussion_r1839376715 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/TaskBalancedSlotSharingStrategy.java: ## @@ -0,0 +1,77 @@ +/* + * Licensed to th

Re: [PR] [FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler [flink]

2024-11-12 Thread via GitHub
RocMarshal commented on PR #25504: URL: https://github.com/apache/flink/pull/25504#issuecomment-2472353537 blocked by https://github.com/apache/flink/pull/25647 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

Re: [PR] [FLINK-36093][transform] fix preTransformoperator wrongly filters columns when multiple transform [flink-cdc]

2024-11-12 Thread via GitHub
MOBIN-F commented on PR #3572: URL: https://github.com/apache/flink-cdc/pull/3572#issuecomment-2472340148 oceanbase tests failure,but it seems to have nothing to do with this PR -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-36691) Support configuration to enable tasks balancing at slot level for Default Scheduler

2024-11-12 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-36691: --- Description: First support balanced task allocation in the Default Scheduler slot dimension in strea

[PR] [BP release-3.2][FLINK-36541][pipeline-connector][paimon] Pass checkpointId to StoreSinkWrite#prepareCommit correctly [flink-cdc]

2024-11-12 Thread via GitHub
lvyanquan opened a new pull request, #3727: URL: https://github.com/apache/flink-cdc/pull/3727 (cherry picked from commit f38341b02ed4cfc3c77d28c795e330be2966482e) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

Re: [PR] [FLINK-36572][pipeline-connector][starrocks] Fix the issue that the local time zone is wrongly set [flink-cdc]

2024-11-12 Thread via GitHub
yuxiqian commented on PR #3655: URL: https://github.com/apache/flink-cdc/pull/3655#issuecomment-2472274950 Could @herunkang2018 please backport it to release-3.2 branch? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-36696) JDBC Autoscaler plugin should use DataSource and not connection

2024-11-12 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36696: Issue Type: Bug (was: Improvement) > JDBC Autoscaler plugin should use DataSource and not connection > --

[jira] [Created] (FLINK-36699) Fix nullability when converting cdc data type to flink data type

2024-11-12 Thread Xiao Huang (Jira)
Xiao Huang created FLINK-36699: -- Summary: Fix nullability when converting cdc data type to flink data type Key: FLINK-36699 URL: https://issues.apache.org/jira/browse/FLINK-36699 Project: Flink

[jira] [Assigned] (FLINK-36696) JDBC Autoscaler plugin should use DataSource and not connection

2024-11-12 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-36696: --- Assignee: Sai Sharath Dandi > JDBC Autoscaler plugin should use DataSource and not connection > ---

Re: [PR] [FLINK-36375][cdc-runtime] fix missing default value in AddColumnEvent/RenameColunEvent [flink-cdc]

2024-11-12 Thread via GitHub
leonardBang commented on PR #3622: URL: https://github.com/apache/flink-cdc/pull/3622#issuecomment-2472213007 @qg-lin Would you like to backport this PR for branch `release-3.2`? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-36613] Fix unstable RescaleCheckpointManuallyITCase [flink]

2024-11-12 Thread via GitHub
Zakelly merged PR #25642: URL: https://github.com/apache/flink/pull/25642 -- 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] [Commented] (FLINK-36476) Remove all deprecated methods under public APIs in table modules and adapt the related tests to make them pass

2024-11-12 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897795#comment-17897795 ] xuyang commented on FLINK-36476: If I'm misunderstanding, please correct me. It seems th

[jira] [Commented] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP

2024-11-12 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897801#comment-17897801 ] Zakelly Lan commented on FLINK-36613: - Merge 73c120d...6fe39c6 into master > Resca

[PR] [FLINK-36698][pipeline-connector][elasticsearch] Elasticsearch Pipeline Connector support index sharding [flink-cdc]

2024-11-12 Thread via GitHub
beryllw opened a new pull request, #3723: URL: https://github.com/apache/flink-cdc/pull/3723 Support Elasticsearch sink to write into different indexes based on a specific field. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Commented] (FLINK-36696) JDBC Autoscaler plugin should use DataSource and not connection

2024-11-12 Thread Sai Sharath Dandi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897797#comment-17897797 ] Sai Sharath Dandi commented on FLINK-36696: --- [~fanrui] Sure! Please assign the

[jira] [Updated] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding

2024-11-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36698: --- Labels: pull-request-available (was: ) > Elasticsearch Pipeline Connector support index sha

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

2024-11-12 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897794#comment-17897794 ] xuyang commented on FLINK-36476: [~davidradl]  My intention is mostly in line with your

[jira] [Created] (FLINK-36698) Elasticsearch Pipeline Connector support index sharding

2024-11-12 Thread JunboWang (Jira)
JunboWang created FLINK-36698: - Summary: Elasticsearch Pipeline Connector support index sharding Key: FLINK-36698 URL: https://issues.apache.org/jira/browse/FLINK-36698 Project: Flink Issue Type:

Re: [PR] [FLINK-36646][helm] Add required Java Opts to allow Java 17 based job images [flink-kubernetes-operator]

2024-11-12 Thread via GitHub
SamBarker commented on PR #915: URL: https://github.com/apache/flink-kubernetes-operator/pull/915#issuecomment-2472151543 > The options were added under the env.java.default-opts.all config option as these will be combined with any user supplied env.java.opts.all in the FlinkDeployment CR.

[jira] [Commented] (FLINK-36696) JDBC Autoscaler plugin should use DataSource and not connection

2024-11-12 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897791#comment-17897791 ] Rui Fan commented on FLINK-36696: - Thanks [~dsaisharath] for the report! :) I checked i

[jira] [Created] (FLINK-36697) Quickly evolving schema change in Doris fails

2024-11-12 Thread yux (Jira)
yux created FLINK-36697: --- Summary: Quickly evolving schema change in Doris fails Key: FLINK-36697 URL: https://issues.apache.org/jira/browse/FLINK-36697 Project: Flink Issue Type: Bug Compone

Re: [PR] [FLINK-35713][cdc-compose] Add sink PARALLELISM for flink-cdc. [flink-cdc]

2024-11-12 Thread via GitHub
github-actions[bot] commented on PR #3438: URL: https://github.com/apache/flink-cdc/pull/3438#issuecomment-2471931339 This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encou

Re: [PR] [FLINK-35713][cdc-compose] Add sink PARALLELISM for flink-cdc. [flink-cdc]

2024-11-12 Thread via GitHub
github-actions[bot] closed pull request #3438: [FLINK-35713][cdc-compose] Add sink PARALLELISM for flink-cdc. URL: https://github.com/apache/flink-cdc/pull/3438 -- 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

Re: [PR] [FLINK-35762] Cache hashCode for TableID & Transform descriptors [flink-cdc]

2024-11-12 Thread via GitHub
github-actions[bot] closed pull request #3454: [FLINK-35762] Cache hashCode for TableID & Transform descriptors URL: https://github.com/apache/flink-cdc/pull/3454 -- 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] [FLINK-35634] Add CdcUp playground CLI scripts [flink-cdc]

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

Re: [PR] [FLINK-35762] Cache hashCode for TableID & Transform descriptors [flink-cdc]

2024-11-12 Thread via GitHub
github-actions[bot] commented on PR #3454: URL: https://github.com/apache/flink-cdc/pull/3454#issuecomment-2471930611 This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encou

Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-hbase]

2024-11-12 Thread via GitHub
boring-cyborg[bot] commented on PR #52: URL: https://github.com/apache/flink-connector-hbase/pull/52#issuecomment-2471264225 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is a

[PR] [FLINK-36595][docs] Add docs data file [flink-connector-cassandra]

2024-11-12 Thread via GitHub
nicusX opened a new pull request, #31: URL: https://github.com/apache/flink-connector-cassandra/pull/31 Add missing docs data file ### Purpose of the change * Add missing docs data file for master version ### Significant changes No significant changes -- This is

[PR] [FLINK-36595][docs] Explicitly set connector compatibility as string [flink-connector-cassandra]

2024-11-12 Thread via GitHub
nicusX opened a new pull request, #30: URL: https://github.com/apache/flink-connector-cassandra/pull/30 Explicitly set connector compatibility as string to prevent version comparison mismatch ### Purpose of the change * Add missing docs data file * Add supported Flink versio

Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string [flink-connector-cassandra]

2024-11-12 Thread via GitHub
boring-cyborg[bot] commented on PR #30: URL: https://github.com/apache/flink-connector-cassandra/pull/30#issuecomment-2471356602 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This

[jira] [Created] (FLINK-36696) JDBC Autoscaler plugin should use DataSource and not connection

2024-11-12 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-36696: - Summary: JDBC Autoscaler plugin should use DataSource and not connection Key: FLINK-36696 URL: https://issues.apache.org/jira/browse/FLINK-36696 Project: Fl

Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-opensearch]

2024-11-12 Thread via GitHub
nicusX commented on code in PR #49: URL: https://github.com/apache/flink-connector-opensearch/pull/49#discussion_r1838605009 ## docs/data/opensearch.yml: ## @@ -17,6 +17,7 @@ version: 2.0.0-SN

[PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-jdbc]

2024-11-12 Thread via GitHub
hlteoh37 opened a new pull request, #147: URL: https://github.com/apache/flink-connector-jdbc/pull/147 …to prevent version comparison mismatch ## Purpose of the change * Set version as string to prevent version comparison mismatch. Issue has happened for other connectors too :

Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-jdbc]

2024-11-12 Thread via GitHub
boring-cyborg[bot] commented on PR #147: URL: https://github.com/apache/flink-connector-jdbc/pull/147#issuecomment-2471269220 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-pulsar]

2024-11-12 Thread via GitHub
boring-cyborg[bot] commented on PR #98: URL: https://github.com/apache/flink-connector-pulsar/pull/98#issuecomment-2471286110 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-pulsar]

2024-11-12 Thread via GitHub
hlteoh37 opened a new pull request, #98: URL: https://github.com/apache/flink-connector-pulsar/pull/98 …to prevent version comparison mismatch ## Purpose of the change * Set version as string to prevent version comparison mismatch. Issue has happened for other connectors too :

Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-opensearch]

2024-11-12 Thread via GitHub
hlteoh37 commented on PR #49: URL: https://github.com/apache/flink-connector-opensearch/pull/49#issuecomment-2471286885 @snuyanzin it would be good to get your validation on this! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-gcp-pubsub]

2024-11-12 Thread via GitHub
hlteoh37 opened a new pull request, #34: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/34 …to prevent version comparison mismatch ## Purpose of the change * Set version as string to prevent version comparison mismatch. Issue has happened for other connectors to

Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-opensearch]

2024-11-12 Thread via GitHub
boring-cyborg[bot] commented on PR #49: URL: https://github.com/apache/flink-connector-opensearch/pull/49#issuecomment-2471281165 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This

[PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-opensearch]

2024-11-12 Thread via GitHub
hlteoh37 opened a new pull request, #49: URL: https://github.com/apache/flink-connector-opensearch/pull/49 …to prevent version comparison mismatch ## Purpose of the change * Set version as string to prevent version comparison mismatch. Issue has happened for other connectors to

Re: [PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-gcp-pubsub]

2024-11-12 Thread via GitHub
boring-cyborg[bot] commented on PR #34: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/34#issuecomment-2471266545 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This

[PR] [FLINK-36595][docs] Explicitly set connector compatibility as string … [flink-connector-hbase]

2024-11-12 Thread via GitHub
hlteoh37 opened a new pull request, #52: URL: https://github.com/apache/flink-connector-hbase/pull/52 …to prevent version comparison mismatch ## Purpose of the change * Set version as string to prevent version comparison mismatch. Issue has happened for other connectors too :

Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink]

2024-11-12 Thread via GitHub
MartijnVisser commented on PR #25646: URL: https://github.com/apache/flink/pull/25646#issuecomment-2471224425 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comm

[jira] [Commented] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897686#comment-17897686 ] Hong Liang Teoh commented on FLINK-36595: - flink-connector-aws [https://github.

[jira] [Commented] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897685#comment-17897685 ] Hong Liang Teoh commented on FLINK-36595: - flink-connector-prometheus [https://

[jira] [Reopened] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reopened FLINK-36595: - Assignee: Hong Liang Teoh (was: Aleksandr Pilipenko) > Supported Flink version for co

[jira] [Assigned] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-36595: --- Assignee: Aleksandr Pilipenko (was: Hong Liang Teoh) > Supported Flink version for

[jira] [Commented] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

2024-11-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897684#comment-17897684 ] Hong Liang Teoh commented on FLINK-36595: - Performing this fix for the rest of t

[PR] Upgrade com.squareup.okio:okio [flink]

2024-11-12 Thread via GitHub
g-s-eire opened a new pull request, #25649: URL: https://github.com/apache/flink/pull/25649 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

Re: [PR] Upgrade com.squareup.okio:okio [flink]

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

Re: [PR] [hotfix][docs] Explicitly set connector compatibility as string to pr… [flink-connector-prometheus]

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

Re: [PR] [hotfix][docs] Explicitly set connector compatibility as string to pr… [flink-connector-aws]

2024-11-12 Thread via GitHub
hlteoh37 merged PR #183: URL: https://github.com/apache/flink-connector-aws/pull/183 -- 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...@

[PR] [hotfix][docs] Explicitly set connector compatibility as string to pr… [flink-connector-prometheus]

2024-11-12 Thread via GitHub
hlteoh37 opened a new pull request, #21: URL: https://github.com/apache/flink-connector-prometheus/pull/21 …event version comparison mismatch ## Purpose of the change Set version as string to prevent version comparison mismatch. Issue has happened for other connectors too : ht

[PR] [hotfix][docs] Explicitly set connector compatibility as string to pr… [flink-connector-aws]

2024-11-12 Thread via GitHub
hlteoh37 opened a new pull request, #183: URL: https://github.com/apache/flink-connector-aws/pull/183 …event version comparison mismatch ## Purpose of the change * Set version as string to prevent version comparison mismatch. Issue has happened for other connectors too : https

Re: [PR] [hotfix][ci] Shorten CI workflow tag prefixes to improve CI workflow readability [flink-cdc]

2024-11-12 Thread via GitHub
leonardBang commented on code in PR #3722: URL: https://github.com/apache/flink-cdc/pull/3722#discussion_r1838377265 ## .github/workflows/flink_cdc_migration_test.yml: ## @@ -74,7 +74,7 @@ jobs: run: cd conf && docker compose down working-directory: ./tools/mig

[jira] [Resolved] (FLINK-36560) Fix the issue of timestamp_ltz increasing by 8 hours in Paimon

2024-11-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36560. Resolution: Fixed > Fix the issue of timestamp_ltz increasing by 8 hours in Paimon > -

Re: [PR] [BP release 3.2][FLINK-36560][pipeline-connector][paimon] Fix the issue that timestamp_ltz field is not correctly converted [flink-cdc]

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

[PR] [hotfix] Make cutting patch version in stage_jars.sh platform-agnostic [flink-connector-shared-utils]

2024-11-12 Thread via GitHub
ferenc-csaky opened a new pull request, #42: URL: https://github.com/apache/flink-connector-shared-utils/pull/42 (no comment) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

Re: [PR] [hotfix][ci] Shorten CI workflow tag prefixes to improve CI workflow readability [flink-cdc]

2024-11-12 Thread via GitHub
leonardBang commented on code in PR #3722: URL: https://github.com/apache/flink-cdc/pull/3722#discussion_r1838378377 ## .github/workflows/flink_cdc_migration_test.yml: ## @@ -19,7 +19,7 @@ on: workflow_call: jobs: - migration_test_ut: + unit_test: Review Comment: mis

Re: [PR] [hotfix][ci] Shorten CI workflow tag prefixes to improve CI workflow readability [flink-cdc]

2024-11-12 Thread via GitHub
leonardBang commented on code in PR #3722: URL: https://github.com/apache/flink-cdc/pull/3722#discussion_r1838378142 ## .github/workflows/flink_cdc_migration_test.yml: ## @@ -35,7 +35,7 @@ jobs: - name: Run migration tests run: cd flink-cdc-migration-tests && mvn

Re: [PR] [hotfix][ci] Shorten CI workflow tag prefixes to improve CI workflow readability [flink-cdc]

2024-11-12 Thread via GitHub
leonardBang commented on code in PR #3722: URL: https://github.com/apache/flink-cdc/pull/3722#discussion_r1838378142 ## .github/workflows/flink_cdc_migration_test.yml: ## @@ -35,7 +35,7 @@ jobs: - name: Run migration tests run: cd flink-cdc-migration-tests && mvn

Re: [PR] [hotfix][e2e] Temporarily disable multiple parallelism E2e cases [flink-cdc]

2024-11-12 Thread via GitHub
leonardBang merged PR #3718: URL: https://github.com/apache/flink-cdc/pull/3718 -- 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] [Comment Edited] (FLINK-16077) Translate "Custom State Serialization" page into Chinese

2024-11-12 Thread BoShuai Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896580#comment-17896580 ] BoShuai Li edited comment on FLINK-16077 at 11/12/24 4:05 PM:

Re: [PR] [FLINK-16155][docs] Translate "Operator/Process Function" into Chinese [flink]

2024-11-12 Thread via GitHub
liboshuai01 commented on code in PR #25624: URL: https://github.com/apache/flink/pull/25624#discussion_r1838352255 ## docs/content.zh/docs/dev/datastream/operators/process_function.md: ## @@ -26,68 +26,61 @@ under the License. # Process Function -## The ProcessFunction +##

Re: [PR] [FLINK-35067][cdc-connector][postgres] Adding metadata 'row_kind' for Postgres CDC Connector. [flink-cdc]

2024-11-12 Thread via GitHub
lvyanquan commented on code in PR #3716: URL: https://github.com/apache/flink-cdc/pull/3716#discussion_r1838358625 ## flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableFactoryTest.java:

Re: [PR] [FLINK-16077][docs] Translate "Custom State Serialization" page into Chinese [flink]

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

Re: [PR] [FLINK-16155][docs] Translate "Operator/Process Function" into Chinese [flink]

2024-11-12 Thread via GitHub
liboshuai01 commented on code in PR #25624: URL: https://github.com/apache/flink/pull/25624#discussion_r1838351238 ## docs/content.zh/docs/dev/datastream/operators/process_function.md: ## @@ -26,68 +26,61 @@ under the License. # Process Function -## The ProcessFunction +##

Re: [PR] [FLINK-16155][docs] Translate "Operator/Process Function" into Chinese [flink]

2024-11-12 Thread via GitHub
liboshuai01 commented on code in PR #25624: URL: https://github.com/apache/flink/pull/25624#discussion_r1838350358 ## docs/content.zh/docs/dev/datastream/operators/process_function.md: ## @@ -26,68 +26,61 @@ under the License. # Process Function -## The ProcessFunction +##

Re: [PR] [FLINK-36670][core] Optimize port range out-of-bounds exception log [flink]

2024-11-12 Thread via GitHub
Gianzie closed pull request #25620: [FLINK-36670][core] Optimize port range out-of-bounds exception log URL: https://github.com/apache/flink/pull/25620 -- 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 t

Re: [PR] [FLINK-16155][docs] Translate "Operator/Process Function" into Chinese [flink]

2024-11-12 Thread via GitHub
liboshuai01 commented on code in PR #25624: URL: https://github.com/apache/flink/pull/25624#discussion_r1838349598 ## docs/content.zh/docs/dev/datastream/operators/process_function.md: ## @@ -26,68 +26,61 @@ under the License. # Process Function -## The ProcessFunction +##

[jira] [Updated] (FLINK-36560) Fix the issue of timestamp_ltz increasing by 8 hours in Paimon

2024-11-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36560: --- Fix Version/s: cdc-3.3.0 > Fix the issue of timestamp_ltz increasing by 8 hours in Paimon >

Re: [PR] [FLINK-36593][runtime] Backport io.airlift:aircompressor upgrade to 0.27 [flink]

2024-11-12 Thread via GitHub
tomncooper commented on PR #25606: URL: https://github.com/apache/flink/pull/25606#issuecomment-2470854143 Well spotted @gracegrimwood, thanks! -- 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] [FLINK-16077][docs] Translate "Custom State Serialization" page into Chinese [flink]

2024-11-12 Thread via GitHub
liboshuai01 commented on PR #25648: URL: https://github.com/apache/flink/pull/25648#issuecomment-2470852544 @leonardBang @PatrickRen @lvyanquan @loserwang1024 Excuse me, do you have time to take a look at this? -- This is an automated message from the Apache Git Service. To respond to the

[PR] [FLINK-16077][docs] Translate "Custom State Serialization" page into Chinese [flink]

2024-11-12 Thread via GitHub
liboshuai01 opened a new pull request, #25648: URL: https://github.com/apache/flink/pull/25648 What is the purpose of the change --- Translate Custom State Serialization page into Chinese Verifying this change --- This change is a trivial rework / code cleanup without any t

Re: [PR] [FLINK-16077][docs] Translate "Custom State Serialization" page into Chinese [flink]

2024-11-12 Thread via GitHub
liboshuai01 closed pull request #25625: [FLINK-16077][docs] Translate "Custom State Serialization" page into Chinese URL: https://github.com/apache/flink/pull/25625 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Comment Edited] (FLINK-36560) Fix the issue of timestamp_ltz increasing by 8 hours in Paimon

2024-11-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897088#comment-17897088 ] Leonard Xu edited comment on FLINK-36560 at 11/12/24 3:18 PM:

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

2024-11-12 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897594#comment-17897594 ] david radley commented on FLINK-36476: -- [~xuyangzhong] I am a bit confused : I sa

Re: [PR] [FLINK-36670][core] Optimize port range out-of-bounds exception log [flink]

2024-11-12 Thread via GitHub
Gianzie closed pull request #25620: [FLINK-36670][core] Optimize port range out-of-bounds exception log URL: https://github.com/apache/flink/pull/25620 -- 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 t

Re: [PR] Bumps org.apache.calcite:calcite-core from 1.16.0 to 1.32.0. [flink]

2024-11-12 Thread via GitHub
MartijnVisser closed pull request #25645: Bumps org.apache.calcite:calcite-core from 1.16.0 to 1.32.0. URL: https://github.com/apache/flink/pull/25645 -- 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

[PR] [FLINK-35966][runtime] Introduce the TASKS for TaskManagerLoadBalanceMode enum [flink]

2024-11-12 Thread via GitHub
RocMarshal opened a new pull request, #25647: URL: https://github.com/apache/flink/pull/25647 ## What is the purpose of the change - [FLINK-35966][runtime] Introduce the TASKS for TaskManagerLoadBalanceMode enum - [FLINK-36691][runtime] Support configuration to enable tasks

[jira] [Updated] (FLINK-35966) Introduce the TASKS for TaskManagerLoadBalanceMode enum

2024-11-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35966: --- Labels: pull-request-available (was: ) > Introduce the TASKS for TaskManagerLoadBalanceMode

Re: [PR] [FLINK-35966][runtime] Introduce the TASKS for TaskManagerLoadBalanceMode enum [flink]

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

Re: [PR] [FLINK-36669][pipeline-connector][ES] The flink version of ES should use parent's pom [flink-cdc]

2024-11-12 Thread via GitHub
Gianzie closed pull request #3692: [FLINK-36669][pipeline-connector][ES] The flink version of ES should use parent's pom URL: https://github.com/apache/flink-cdc/pull/3692 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

Re: [PR] Bumps org.apache.calcite:calcite-core from 1.16.0 to 1.32.0. [flink]

2024-11-12 Thread via GitHub
MartijnVisser commented on PR #25645: URL: https://github.com/apache/flink/pull/25645#issuecomment-2470723467 @uuserf16 Please check out the code contribution guide https://flink.apache.org/how-to-contribute/contribute-code/ Do note that Calcite upgrades require much more then just a sim

Re: [PR] [FLINK-36646][helm] Add required Java Opts to allow Java 17 based job images [flink-kubernetes-operator]

2024-11-12 Thread via GitHub
tomncooper commented on PR #915: URL: https://github.com/apache/flink-kubernetes-operator/pull/915#issuecomment-2470713908 One question I had was how to ensure these opts stay in sync with the upstream Flink Distribution's opts? Should we add a script to sync them with a tagged release fro

[PR] [FLINK-36646][helm] Add required Java Opts to allow Java 17 based job images [flink-kubernetes-operator]

2024-11-12 Thread via GitHub
tomncooper opened a new pull request, #915: URL: https://github.com/apache/flink-kubernetes-operator/pull/915 ## What is the purpose of the change From Java 16 onwards, the project jigsaw java opts are now mandatory. To allow Java 17 based job images, we need to include the [java opt

Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink]

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

[jira] [Updated] (FLINK-36695) Bump Parquet dependency

2024-11-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36695: --- Labels: pull-request-available (was: ) > Bump Parquet dependency > ---

  1   2   >