[jira] [Updated] (FLINK-38164) MySQL connector supportLONG and LONG VARCHAR type

2025-07-30 Thread ZhangChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhangChao updated FLINK-38164: -- Description: In MySQL, LONG and LONG VARCHAR map to the MEDIUMTEXT data type. MySQL-pipeline-connector

[jira] [Created] (FLINK-38164) MySQL connector supportLONG and LONG VARCHAR type

2025-07-30 Thread ZhangChao (Jira)
ZhangChao created FLINK-38164: - Summary: MySQL connector supportLONG and LONG VARCHAR type Key: FLINK-38164 URL: https://issues.apache.org/jira/browse/FLINK-38164 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-38163) Adaptive Scheduler: Support record and query rescales hisotry.

2025-07-30 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18011099#comment-18011099 ] RocMarshal commented on FLINK-38163: The POC is ready [https://github.com/RocMarshal

[jira] [Updated] (FLINK-38163) Adaptive Scheduler: Support record and query rescales hisotry.

2025-07-30 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-38163: --- Description: https://cwiki.apache.org/confluence/display/FLINK/FLIP-495%3A+Support+AdaptiveScheduler

[jira] [Created] (FLINK-38163) Adaptive Scheduler: Support record and query rescales hisotry.

2025-07-30 Thread RocMarshal (Jira)
RocMarshal created FLINK-38163: -- Summary: Adaptive Scheduler: Support record and query rescales hisotry. Key: FLINK-38163 URL: https://issues.apache.org/jira/browse/FLINK-38163 Project: Flink I

Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc]

2025-07-30 Thread via GitHub
leonardBang commented on PR #3968: URL: https://github.com/apache/flink-cdc/pull/3968#issuecomment-3138732974 Thanks @Mrart and all who involved this feature for the great work ! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Closed] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots

2025-07-30 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal closed FLINK-36426. -- Resolution: Won't Fix > Introduce the strategy for adaptive scheduler to control state locality > pre

Re: [PR] [FLINK-26944][Table SQL/API] Add ADD_MONTHS supported in SQL and Table API [flink]

2025-07-30 Thread via GitHub
github-actions[bot] closed pull request #20323: [FLINK-26944][Table SQL/API] Add ADD_MONTHS supported in SQL and Table API URL: https://github.com/apache/flink/pull/20323 -- 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-26944][Table SQL/API] Add ADD_MONTHS supported in SQL and Table API [flink]

2025-07-30 Thread via GitHub
github-actions[bot] commented on PR #20323: URL: https://github.com/apache/flink/pull/20323#issuecomment-3138707942 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] Hotfix Fix 2.1 announcement page via align markdown header [flink-web]

2025-07-30 Thread via GitHub
lsyldliu merged PR #802: URL: https://github.com/apache/flink-web/pull/802 -- 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.apac

[PR] Hotfix Fix 2.1 announcement page via align markdown header [flink-web]

2025-07-30 Thread via GitHub
leonardBang opened a new pull request, #802: URL: https://github.com/apache/flink-web/pull/802 Fix 2.1 announcement page via align markdown header -- 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-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc]

2025-07-30 Thread via GitHub
lvyanquan commented on PR #3968: URL: https://github.com/apache/flink-cdc/pull/3968#issuecomment-3138644401 Thanks @Mrart for this contribution, merged. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc]

2025-07-30 Thread via GitHub
lvyanquan merged PR #3968: URL: https://github.com/apache/flink-cdc/pull/3968 -- 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] [api][python] Introduce Prompt, Tool and ChatModel in python [flink-agents]

2025-07-30 Thread via GitHub
xintongsong commented on code in PR #81: URL: https://github.com/apache/flink-agents/pull/81#discussion_r2244241752 ## python/flink_agents/api/tools/utils.py: ## @@ -0,0 +1,171 @@ + +# Licensed to t

Re: [PR] Rebuild website [flink-web]

2025-07-30 Thread via GitHub
lincoln-lil closed pull request #801: Rebuild website URL: https://github.com/apache/flink-web/pull/801 -- 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:

Re: [PR] Rebuild website [flink-web]

2025-07-30 Thread via GitHub
lincoln-lil commented on PR #801: URL: https://github.com/apache/flink-web/pull/801#issuecomment-3138624168 Unexpected non new content generated -- 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] [Python][Optimisation] Introduced caching mechanism to reuse existing PythonFunction instances for identical (module, qualname) pairs. [flink-agents]

2025-07-30 Thread via GitHub
xintongsong merged PR #72: URL: https://github.com/apache/flink-agents/pull/72 -- 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] [Updated] (FLINK-38141) Iceberg sink has an incorrect type conversion

2025-07-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38141: --- Labels: CDC Sink iceberg pull-request-available (was: CDC Sink iceberg) > Iceberg sink has

[PR] [FLINK-38141][pipeline-connector/iceberg] Fix iceberg connector incorrect type mapping [flink-cdc]

2025-07-30 Thread via GitHub
doovvv opened a new pull request, #4070: URL: https://github.com/apache/flink-cdc/pull/4070 According to the Iceberg documentation https://iceberg.apache.org/docs/nightly/flink/#flink-to-iceberg, the CDC type TINYINT should be mapped to the Iceberg type INTEGER. However, in the code implem

[PR] Rebuild website [flink-web]

2025-07-30 Thread via GitHub
lincoln-lil opened a new pull request, #801: URL: https://github.com/apache/flink-web/pull/801 rebuild website for 2.1 release -- 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] Add Flink 2.1.0 release [flink-web]

2025-07-30 Thread via GitHub
lsyldliu merged PR #800: URL: https://github.com/apache/flink-web/pull/800 -- 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.apac

[PR] [hotfix] Fix security issues. [flink-cdc]

2025-07-30 Thread via GitHub
lvyanquan opened a new pull request, #4069: URL: https://github.com/apache/flink-cdc/pull/4069 (no comment) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe,

Re: [PR] [runtime-web] chore: bump angular to v19 [flink]

2025-07-30 Thread via GitHub
Laffery commented on PR #26848: URL: https://github.com/apache/flink/pull/26848#issuecomment-3138301338 This is a test pr to run azure ci, I will close it after the CI pass. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail

2025-07-30 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18011062#comment-18011062 ] Sergey Nuyanzin commented on FLINK-38162: - yes, some reproducible stuff would be

Re: [PR] [FLINK-36631] add oracle read data by specific offset [flink-cdc]

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

[jira] [Assigned] (FLINK-38093) Update version of Fabric8 to 7.3.1

2025-07-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-38093: -- Assignee: Mate Czagany > Update version of Fabric8 to 7.3.1 > ---

[jira] [Closed] (FLINK-38093) Update version of Fabric8 to 7.3.1

2025-07-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-38093. -- Fix Version/s: 2.2.0 Resolution: Fixed merged to main e26d46ba0db210c79dc1f378440a559145073e3a

Re: [PR] [FLINK-38093][k8s] Bump Fabric8 version to 7.3.1 [flink]

2025-07-30 Thread via GitHub
gyfora merged PR #26829: URL: https://github.com/apache/flink/pull/26829 -- 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-38093][k8s] Bump Fabric8 version to 7.3.1 [flink]

2025-07-30 Thread via GitHub
mateczagany commented on PR #26829: URL: https://github.com/apache/flink/pull/26829#issuecomment-3137536543 @gyfora Yes, I have tested this on my local desktop with the operator and checkpoints enabled, all looked good there. -- This is an automated message from the Apache Git Service. To

Re: [PR] [hotfix] Backport Improvement to 4.0 preparing 4.0.1 release [flink-connector-kafka]

2025-07-30 Thread via GitHub
fapaul merged PR #186: URL: https://github.com/apache/flink-connector-kafka/pull/186 -- 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] [hotfix] Set version to 4.0-SNAPSHOT [flink-connector-kafka]

2025-07-30 Thread via GitHub
fapaul merged PR #184: URL: https://github.com/apache/flink-connector-kafka/pull/184 -- 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] [hotfix] Set version to 5.0-SNAPSHOT [flink-connector-kafka]

2025-07-30 Thread via GitHub
boring-cyborg[bot] commented on PR #183: URL: https://github.com/apache/flink-connector-kafka/pull/183#issuecomment-3137349030 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log o

Re: [PR] [hotfix] Set version to 5.0-SNAPSHOT [flink-connector-kafka]

2025-07-30 Thread via GitHub
fapaul merged PR #183: URL: https://github.com/apache/flink-connector-kafka/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...@

Re: [PR] [hotfix] Backport Improvement to 4.0 preparing 4.0.1 release [flink-connector-kafka]

2025-07-30 Thread via GitHub
fapaul commented on PR #186: URL: https://github.com/apache/flink-connector-kafka/pull/186#issuecomment-3137310534 cc @tomncooper we need to backport this first before starting the release for 4.0.1 -- This is an automated message from the Apache Git Service. To respond to the message, p

[PR] [hotfix] Backport Improvement to 4.0 preparing 4.0.1 release [flink-connector-kafka]

2025-07-30 Thread via GitHub
fapaul opened a new pull request, #186: URL: https://github.com/apache/flink-connector-kafka/pull/186 We want to release 4.0.1 soon with the updated depedencies but the commits on this PR haven't been backported. -- This is an automated message from the Apache Git Service. To respond to t

[PR] [hotfix] Set version to 3.4-SNAPSHOT [flink-connector-kafka]

2025-07-30 Thread via GitHub
fapaul opened a new pull request, #185: URL: https://github.com/apache/flink-connector-kafka/pull/185 During the release, we accidentally overwrote the snapshot version on the branch. The fixed versions are only meant to be used on release tags but not on the active branches. -- This is

[PR] [hotfix] Set version to 4.0-SNAPSHOT [flink-connector-kafka]

2025-07-30 Thread via GitHub
fapaul opened a new pull request, #184: URL: https://github.com/apache/flink-connector-kafka/pull/184 During the release, we accidentally overwrote the snapshot version on the branch. The fixed versions are only meant to be used on release tags but not on the active branches. -- This is

[jira] [Commented] (FLINK-30656) Provide more logs for schema compatibility check

2025-07-30 Thread Nick M (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010982#comment-18010982 ] Nick M commented on FLINK-30656: [~masteryhx] any news? I have a lot of problems with th

Re: [PR] [hotfix] Set version to 5.0-SNAPSHOT [flink-connector-kafka]

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

[PR] [hotfix] Set version to 5.0-SNAPSHOT [flink-connector-kafka]

2025-07-30 Thread via GitHub
fapaul opened a new pull request, #183: URL: https://github.com/apache/flink-connector-kafka/pull/183 This PR prepares the main branch for the upcoming Kafka upgrade to 4.x that will remove support for older Kafka servers hence the new major version. -- This is an automated message from t

[jira] [Updated] (FLINK-37983) Upgrade Kafka Client version to 3.9.1

2025-07-30 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-37983: Fix Version/s: kafka-4.0.1 (was: kafka-4.1.0) > Upgrade Kafka Client versio

[jira] [Updated] (FLINK-37714) KafkaTableITCase generates artifacts in main path

2025-07-30 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-37714: Fix Version/s: kafka-4.0.1 (was: kafka-4.1.0) > KafkaTableITCase generates

[jira] [Updated] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project

2025-07-30 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-38063: Fix Version/s: kafka-4.0.1 (was: kafka-4.1.0) > Update dependencies in the

[jira] [Updated] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail

2025-07-30 Thread Nic Townsend (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nic Townsend updated FLINK-38162: - Description: In the Flink docs for window join - [https://nightlies.apache.org/flink/flink-docs

[jira] [Commented] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail

2025-07-30 Thread Nic Townsend (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010977#comment-18010977 ] Nic Townsend commented on FLINK-38162: -- Note - if this is considered a bug, rather

[jira] [Updated] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail

2025-07-30 Thread Nic Townsend (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nic Townsend updated FLINK-38162: - Description: In the Flink docs for window join - [https://nightlies.apache.org/flink/flink-docs

[jira] [Updated] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail

2025-07-30 Thread Nic Townsend (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nic Townsend updated FLINK-38162: - Description: In the Flink docs for window join - [https://nightlies.apache.org/flink/flink-docs

[jira] [Created] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail

2025-07-30 Thread Nic Townsend (Jira)
Nic Townsend created FLINK-38162: Summary: Use of SQL functions with time attributes causes downstream temporal functions to fail Key: FLINK-38162 URL: https://issues.apache.org/jira/browse/FLINK-38162

[D] Flink Agents - Use Cases and Gap Analysis [flink-agents]

2025-07-30 Thread via GitHub
GitHub user thefalc created a discussion: Flink Agents - Use Cases and Gap Analysis # Overview This document outlines a set of representative enterprise use cases where a multi-agent system offers a practical, scalable solution. Each use case includes: - A description of the real-world prob

[jira] [Updated] (FLINK-38161) PyFlink: Unable to find Pemja library in thread mode when Python dependencies are installed in a separate layer

2025-07-30 Thread Jaydeep Karia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaydeep Karia updated FLINK-38161: -- Description: *Problem Summary* PyFlink applications running in *thread mode* fail at startup

[jira] [Created] (FLINK-38161) PyFlink: Unable to find Pemja library in thread mode when Python dependencies are installed in a separate layer

2025-07-30 Thread Jaydeep Karia (Jira)
Jaydeep Karia created FLINK-38161: - Summary: PyFlink: Unable to find Pemja library in thread mode when Python dependencies are installed in a separate layer Key: FLINK-38161 URL: https://issues.apache.org/jira/bro

Re: [PR] [FLINK-38158][metrics] FLIP-484: Add custom metric variables to operators [flink]

2025-07-30 Thread via GitHub
pnowojski commented on code in PR #26849: URL: https://github.com/apache/flink/pull/26849#discussion_r2243187495 ## flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/InternalOperatorGroupTest.java: ## @@ -30,33 +30,30 @@ import org.apache.flink.runtime.metrics

Re: [D] Community Sync [flink-agents]

2025-07-30 Thread via GitHub
GitHub user xintongsong edited a discussion: Community Sync There's a community sync for discussing developing progress, technical designs and community issues about Flink Agents. Everyone is welcome to join. * Schedule: 3am Wed UTC * [Google Calendar](https://calendar.google.com/calendar/u/

Re: [D] Community Sync [flink-agents]

2025-07-30 Thread via GitHub
GitHub user xintongsong edited a discussion: Community Sync There's a community sync for discussing developing progress, technical designs and community issues about Flink Agents. Everyone is welcome to join. * Schedule: 3am Wed UTC * [Google Calendar](https://calendar.google.com/calendar/u/

Re: [D] Time Plan for the first MVP version of Flink Agents [flink-agents]

2025-07-30 Thread via GitHub
GitHub user xintongsong edited a discussion: Time Plan for the first MVP version of Flink Agents We are targeting a MVP version of Flink Agents (0.1.0) in around end of September. That is 16 weeks from now, and here is a rough time plan. # Phase 1: Week 1-3 (Jun 12 - Jul 2) - [x] Preparation

Re: [PR] [FLINK-38158][metrics] FLIP-484: Add custom metric variables to operators [flink]

2025-07-30 Thread via GitHub
Izeren commented on code in PR #26849: URL: https://github.com/apache/flink/pull/26849#discussion_r2242837417 ## flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/InternalOperatorGroupTest.java: ## @@ -30,33 +30,30 @@ import org.apache.flink.runtime.metrics.du

Re: [PR] [FLINK-38093][k8s] Bump Fabric8 version to 7.3.1 [flink]

2025-07-30 Thread via GitHub
gyfora commented on PR #26829: URL: https://github.com/apache/flink/pull/26829#issuecomment-313637 @mateczagany did you have a chance to test this in a kubernetes env manually? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Assigned] (FLINK-38116) Flink kubernetes operator RequestWatchProgress Error

2025-07-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-38116: -- Assignee: Diljeet Singh > Flink kubernetes operator RequestWatchProgress Error >

[jira] [Updated] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause

2025-07-30 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-33497: Fix Version/s: kafka-5.0.0 (was: kafka-4.1.0) > Update the Kafka connector

Re: [PR] [FLINK-38154][metrics] Add HTTP protocol support to OpenTelemetry reporters [flink]

2025-07-30 Thread via GitHub
flinkbot commented on PR #26850: URL: https://github.com/apache/flink/pull/26850#issuecomment-3136336259 ## CI report: * 4e8e9d86755076ad1f8b6eaae93dacc3e0e9dd74 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter

2025-07-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38154: --- Labels: pull-request-available (was: ) > Add HTTP support to OpenTelemetry Reporter > -

[PR] [FLINK-38154][metrics] Add HTTP protocol support to OpenTelemetry reporters [flink]

2025-07-30 Thread via GitHub
kumar-mallikarjuna opened a new pull request, #26850: URL: https://github.com/apache/flink/pull/26850 ## What is the purpose of the change This pull request adds HTTP protocol support to OpenTelemetry reporters (metrics, events, and traces) in addition to the existing gRPC sup

[jira] [Assigned] (FLINK-38141) Iceberg sink has an incorrect type conversion

2025-07-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-38141: -- Assignee: ZhangChao > Iceberg sink has an incorrect type conversion > ---

[jira] [Commented] (FLINK-38141) Iceberg sink has an incorrect type conversion

2025-07-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010908#comment-18010908 ] Leonard Xu commented on FLINK-38141: Assigned to you [~doovvv]  > Iceberg sink has

[jira] [Created] (FLINK-38160) StarRocks Pipeline connector supports TIME/BINARY/VARBINARY type mapping

2025-07-30 Thread ZhangChao (Jira)
ZhangChao created FLINK-38160: - Summary: StarRocks Pipeline connector supports TIME/BINARY/VARBINARY type mapping Key: FLINK-38160 URL: https://issues.apache.org/jira/browse/FLINK-38160 Project: Flink

[jira] [Comment Edited] (FLINK-38141) Iceberg sink has an incorrect type conversion

2025-07-30 Thread ZhangChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18009859#comment-18009859 ] ZhangChao edited comment on FLINK-38141 at 7/30/25 12:47 PM: -

Re: [PR] [FLINK-38158][metrics] FLIP-484: Add custom metric variables to operators [flink]

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

[jira] [Updated] (FLINK-38158) FLIP-484: Add custom metric variables to operators

2025-07-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38158: --- Labels: pull-request-available (was: ) > FLIP-484: Add custom metric variables to operators

[PR] [FLINK-38158][metrics] FLIP-484: Add custom metric variables to operators [flink]

2025-07-30 Thread via GitHub
pnowojski opened a new pull request, #26849: URL: https://github.com/apache/flink/pull/26849 ## What is the purpose of the change https://cwiki.apache.org/confluence/display/FLINK/FLIP-484%3A+Add+custom+metric+variables+to+operators ## Brief change log Please check indiv

Re: [PR] [FLINK-38134][cdc-common] Cannot recognize DropColumnEvent in method … [flink-cdc]

2025-07-30 Thread via GitHub
tbpure commented on PR #4065: URL: https://github.com/apache/flink-cdc/pull/4065#issuecomment-3135995556 > Hi @tbpure, could you rebase master to fix the CI failure. @lvyanquan, done with it, thx -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [FLINK-37973][table-planner] Add support for right joins to multijoin operator [flink]

2025-07-30 Thread via GitHub
gustavodemorais commented on PR #26810: URL: https://github.com/apache/flink/pull/26810#issuecomment-3135796371 @SteveStevenpoor can you provide a quick description of the tests/changes that are still pending? -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API

2025-07-30 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov reassigned FLINK-32695: - Assignee: Poorvank Bhatia (was: Alexander Fedulov) > Migrate SourceFunction in

[jira] [Updated] (FLINK-37959) supported All postgres sql 14 field types.

2025-07-30 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-37959: Description: [https://www.rockdata.net/docs/14/datatype.html]   like doc ,We need to support ric

Re: [PR] [runtime-web] chore: bump angular to v19 [flink]

2025-07-30 Thread via GitHub
flinkbot commented on PR #26848: URL: https://github.com/apache/flink/pull/26848#issuecomment-3135689113 ## CI report: * 8918f66acd3157177971033f3e7dd26bc6d313f6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [Test][Do NOT MERGE] Test PR to check if the build fails [flink]

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

[PR] [runtime-web] chore: bump angular to v19 [flink]

2025-07-30 Thread via GitHub
Laffery opened a new pull request, #26848: URL: https://github.com/apache/flink/pull/26848 ## What is the purpose of the change Angular framework and NG-ZORRO both have released their stable v19 versions. It is a good time to bump them to the latest. ## Brief change log

[PR] [Test][Do NOT MERGE] Test PR to check if the build fails [flink]

2025-07-30 Thread via GitHub
vssakuru opened a new pull request, #26847: URL: https://github.com/apache/flink/pull/26847 ## 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] [FLINK-32695] [Tests] Migrated TableFactoryHarness.ScanSourceBase to Source V2 [flink]

2025-07-30 Thread via GitHub
flinkbot commented on PR #26846: URL: https://github.com/apache/flink/pull/26846#issuecomment-3135651309 ## CI report: * 2a0c48a0895d7af3759c0246c9d7f2c3d77b0cd5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-32695] [Tests] Migrated TableFactoryHarness.ScanSourceBase to Source V2 [flink]

2025-07-30 Thread via GitHub
Poorvankbhatia opened a new pull request, #26846: URL: https://github.com/apache/flink/pull/26846 ## What is the purpose of the change This PR migrates legacy SourceFunction and SinkFunction implementations in table planner tests from the deprecated legacy APIs to the modern FLIP-27

[jira] [Commented] (FLINK-38159) Update commons-lang3 to mitigate CVE-2025-48924

2025-07-30 Thread David Kornel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010875#comment-18010875 ] David Kornel commented on FLINK-38159: -- PR created https://github.com/apache/flink-

[jira] [Updated] (FLINK-38159) Update commons-lang3 to mitigate CVE-2025-48924

2025-07-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38159: --- Labels: pull-request-available (was: ) > Update commons-lang3 to mitigate CVE-2025-48924 >

[PR] [FLINK-38159] Update commons-lang3 dependency to 3.18.0 [flink-kubernetes-operator]

2025-07-30 Thread via GitHub
kornys opened a new pull request, #1002: URL: https://github.com/apache/flink-kubernetes-operator/pull/1002 ## What is the purpose of the change * Update common-lang3 dependency ## Brief change log - Update common-lang3 dependency version ## Verifying

[jira] [Created] (FLINK-38159) Update commons-lang3 to mitigate CVE-2025-48924

2025-07-30 Thread David Kornel (Jira)
David Kornel created FLINK-38159: Summary: Update commons-lang3 to mitigate CVE-2025-48924 Key: FLINK-38159 URL: https://issues.apache.org/jira/browse/FLINK-38159 Project: Flink Issue Type: I

[jira] [Created] (FLINK-38158) FLIP-484: Add custom metric variables to operators

2025-07-30 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-38158: -- Summary: FLIP-484: Add custom metric variables to operators Key: FLINK-38158 URL: https://issues.apache.org/jira/browse/FLINK-38158 Project: Flink Issue

[jira] [Commented] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline

2025-07-30 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010863#comment-18010863 ] ouyangwulin commented on FLINK-38157: - FLINK-35670 > Postgres cdc pipeline supporte

[jira] [Updated] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline

2025-07-30 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-38157: Parent: FLINK-35670 Issue Type: Sub-task (was: Improvement) > Postgres cdc pipeline suppo

[jira] [Updated] (FLINK-37959) supported All postgres sql 14 field types.

2025-07-30 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-37959: Parent: FLINK-35670 Issue Type: Sub-task (was: Improvement) > supported All postgres sql

[jira] [Assigned] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline

2025-07-30 Thread Yanquan Lv (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv reassigned FLINK-38157: -- Assignee: ouyangwulin > Postgres cdc pipeline supported @experimental options like mysql pipe

[jira] [Created] (FLINK-38157) Postgres cdc pipeline supported @experimental options like mysql pipeline

2025-07-30 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-38157: --- Summary: Postgres cdc pipeline supported @experimental options like mysql pipeline Key: FLINK-38157 URL: https://issues.apache.org/jira/browse/FLINK-38157 Project: Flin

[jira] [Comment Edited] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic

2025-07-30 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010347#comment-18010347 ] Rui Fan edited comment on FLINK-38137 at 7/30/25 8:58 AM: -- Merg

[jira] [Resolved] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic

2025-07-30 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-38137. - Resolution: Fixed > RocksDB State Backend Null Serialization Causes NPE and Asymmetric > (De)Serializat

[jira] [Updated] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic

2025-07-30 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-38137: Fix Version/s: 2.0.1 1.20.3 2.1.1 > RocksDB State Backend Null Seria

[jira] [Commented] (FLINK-37222) Table planner exception when sql client submit job

2025-07-30 Thread Adrian Vasiliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010858#comment-18010858 ] Adrian Vasiliu commented on FLINK-37222: > Merged into release-1.20 at: > 7c9fed

Re: [PR] [FLINK-38137][state] RocksDB and ForSt state backend are compatible with the case where the user value of the map state is null [flink]

2025-07-30 Thread via GitHub
1996fanrui merged PR #26837: URL: https://github.com/apache/flink/pull/26837 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.ap

Re: [PR] [FLINK-38137][state] RocksDB and ForSt state backend are compatible with the case where the user value of the map state is null [flink]

2025-07-30 Thread via GitHub
1996fanrui merged PR #26836: URL: https://github.com/apache/flink/pull/26836 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.ap

Re: [PR] [FLINK-38137][state] RocksDB and ForSt state backend are compatible with the case where the user value of the map state is null [flink]

2025-07-30 Thread via GitHub
1996fanrui merged PR #26838: URL: https://github.com/apache/flink/pull/26838 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.ap

[jira] [Updated] (FLINK-37959) supported All postgres sql 14 field types.

2025-07-30 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-37959: Description: [https://www.rockdata.net/docs/14/datatype.html]   like doc ,We need to support ric

[jira] [Closed] (FLINK-37765) Idea import duplicate modules error.

2025-07-30 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin closed FLINK-37765. --- Resolution: Won't Fix > Idea import duplicate modules error. >

[jira] [Assigned] (FLINK-35670) Support Postgres CDC Pipeline Source

2025-07-30 Thread Yanquan Lv (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanquan Lv reassigned FLINK-35670: -- Assignee: ouyangwulin > Support Postgres CDC Pipeline Source > --

Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc]

2025-07-30 Thread via GitHub
lvyanquan commented on code in PR #3968: URL: https://github.com/apache/flink-cdc/pull/3968#discussion_r2241899366 ## docs/content/docs/connectors/pipeline-connectors/postgres.md: ## @@ -0,0 +1,398 @@ +--- +title: "Postgres" +weight: 2 +type: docs +aliases: +- /connectors/pipeli

  1   2   >