[jira] [Commented] (FLINK-38013) [Release-2.1] Cross team testing

2025-07-18 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008189#comment-18008189 ] dalongliu commented on FLINK-38013: --- All release testing has been done, close it. > [

[jira] [Resolved] (FLINK-38013) [Release-2.1] Cross team testing

2025-07-18 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-38013. --- Resolution: Fixed > [Release-2.1] Cross team testing > > >

[PR] [hotfix]Fix kafka doc properties table error [flink]

2025-07-18 Thread via GitHub
zm99 opened a new pull request, #26812: URL: https://github.com/apache/flink/pull/26812 ## What is the purpose of the change Fix kafka doc properties table error ## Verifying this change This change is a trivial rework / code cleanup without any test c

[jira] [Resolved] (FLINK-38012) [Release-2.1] Review Release Notes in JIRA

2025-07-18 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-38012. --- Assignee: dalongliu Resolution: Fixed > [Release-2.1] Review Release Notes in JIRA > -

[jira] [Commented] (FLINK-38012) [Release-2.1] Review Release Notes in JIRA

2025-07-18 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008188#comment-18008188 ] dalongliu commented on FLINK-38012: --- Manual check. > [Release-2.1] Review Release Not

[jira] [Comment Edited] (FLINK-38017) [Release-2.1] Add release note for release 2.1

2025-07-18 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008186#comment-18008186 ] dalongliu edited comment on FLINK-38017 at 7/19/25 2:29 AM:

[jira] [Resolved] (FLINK-38017) [Release-2.1] Add release note for release 2.1

2025-07-18 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-38017. --- Assignee: dalongliu Resolution: Fixed > [Release-2.1] Add release note for release 2.1 > -

[jira] [Commented] (FLINK-38017) [Release-2.1] Add release note for release 2.1

2025-07-18 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008186#comment-18008186 ] dalongliu commented on FLINK-38017: --- Master branch: 7309fe832cb303c9adf6bfb441790e3d29

Re: [PR] [hotfix]Fix kafka doc properties table error [flink]

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

Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink]

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

Re: [PR] [FLINK-38017][release] Add release note for release 2.1 [flink]

2025-07-18 Thread via GitHub
lsyldliu commented on PR #26778: URL: https://github.com/apache/flink/pull/26778#issuecomment-3091399280 Thanks for all review, merge it. -- 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 speci

[jira] [Commented] (FLINK-38118) The execution.attached=true parameter does not take effect in application mode

2025-07-18 Thread shilei-ly (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008183#comment-18008183 ] shilei-ly commented on FLINK-38118: --- Hi, [~fcsaky]  thanks for your comment. I agree w

[jira] [Commented] (FLINK-38118) The execution.attached=true parameter does not take effect in application mode

2025-07-18 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008158#comment-18008158 ] Ferenc Csaky commented on FLINK-38118: -- Hi! I do not think this is a bug. Even prev

Re: [PR] [FLINK-38109] [flink-runtime] Fix BlobClient address when bindhost is set [flink]

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

[jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host

2025-07-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38109: --- Labels: pull-request-available (was: ) > BlobServer isn't associated with the correct bind-

[PR] [FLINK-38109] [flink-runtime] Fix BlobClient address when bindhost is set [flink]

2025-07-18 Thread via GitHub
rosakng opened a new pull request, #26811: URL: https://github.com/apache/flink/pull/26811 https://issues.apache.org/jira/browse/FLINK-38109 ## What is the purpose of the change The current implementation of BlobServer is to inherit the JobManager bind-host, however theres impl

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

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

[jira] [Updated] (FLINK-37973) Use RightToLeftJoin Rule for MultiJoins

2025-07-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37973: --- Labels: pull-request-available (was: ) > Use RightToLeftJoin Rule for MultiJoins >

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

2025-07-18 Thread via GitHub
SteveStevenpoor opened a new pull request, #26810: URL: https://github.com/apache/flink/pull/26810 ## What is the purpose of the change The newly introduced `MultiJoin` operator currently does not support right joins. Since all right joins are converted to left joins, we need to enabl

Re: [PR] [FLINK-37724] Adds AsyncTableFunction as a fully supported UDF type [flink]

2025-07-18 Thread via GitHub
AlanConfluent commented on PR #26567: URL: https://github.com/apache/flink/pull/26567#issuecomment-3090248330 > @AlanConfluent Given that retry-on-empty-result is an existing behavior, maybe it is OK to check in the code as is. We can do a quick follow up FLIP to improve the behavior. Pleas

Re: [PR] [FLINK-37724] Adds AsyncTableFunction as a fully supported UDF type [flink]

2025-07-18 Thread via GitHub
AlanConfluent commented on code in PR #26567: URL: https://github.com/apache/flink/pull/26567#discussion_r2216591596 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/correlate/async/DelegatingAsyncTableResultFuture.java: ## @@ -29,27 +33,

Re: [PR] [FLINK-38020] Fix NPE in NonTimeRangeUnboundedFunction [flink]

2025-07-18 Thread via GitHub
bvarghese1 commented on PR #26807: URL: https://github.com/apache/flink/pull/26807#issuecomment-3090151302 > Thanks for the fix @bvarghese1! > > Left one minor comment with a suggestion to (IMO) simplify the code a bit. Just let me know if you'd like to keep it this way and we can als

[jira] [Created] (FLINK-38120) FLIP-536 Add latest checkpoint details endpoint

2025-07-18 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-38120: --- Summary: FLIP-536 Add latest checkpoint details endpoint Key: FLINK-38120 URL: https://issues.apache.org/jira/browse/FLINK-38120 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-35746) Add logic to override observed config based on settings observed through REST API

2025-07-18 Thread Nishita Pattanayak (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18008082#comment-18008082 ] Nishita Pattanayak commented on FLINK-35746: [~gyfora] I had a few questions

Re: [PR] [plan][runtime][python] Introduce Resource and Resource Provider in java [flink-agents]

2025-07-18 Thread via GitHub
kitalkuyo-gita commented on PR #71: URL: https://github.com/apache/flink-agents/pull/71#issuecomment-3089294659 > Hi, @kitalkuyo-gita, thanks for your contribution, but there are some basic issues should be settled before we talk about the detail of this PR. > > 1. I think this PR is

Re: [PR] [FLINK-38042] Warn the user on full table scans [flink-connector-cassandra]

2025-07-18 Thread via GitHub
Poorvankbhatia commented on PR #34: URL: https://github.com/apache/flink-connector-cassandra/pull/34#issuecomment-3088955044 LGTM. 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 spec

Re: [I] [Feature][plan][runtime][python] Introduce Resource and Resource Provider in python [flink-agents]

2025-07-18 Thread via GitHub
xintongsong closed issue #68: [Feature][plan][runtime][python] Introduce Resource and Resource Provider in python URL: https://github.com/apache/flink-agents/issues/68 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

Re: [PR] [plan][runtime][python] Introduce Resource and Resource Provider in p… [flink-agents]

2025-07-18 Thread via GitHub
xintongsong merged PR #70: URL: https://github.com/apache/flink-agents/pull/70 -- 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-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN [flink]

2025-07-18 Thread via GitHub
davidradl commented on code in PR #26809: URL: https://github.com/apache/flink/pull/26809#discussion_r2215557321 ## docs/layouts/shortcodes/generated/yarn_config_configuration.html: ## @@ -28,9 +28,9 @@ yarn.application-attempt-failures-validity

Re: [PR] [FLINK-38020] Fix NPE in NonTimeRangeUnboundedFunction [flink]

2025-07-18 Thread via GitHub
davidradl commented on code in PR #26807: URL: https://github.com/apache/flink/pull/26807#discussion_r2215590996 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRangeUnboundedPrecedingFunction.java: ## @@ -422,11 +422,13 @@ p

Re: [PR] [plan][runtime][python] Introduce Resource and Resource Provider in java [flink-agents]

2025-07-18 Thread via GitHub
wenjin272 commented on PR #71: URL: https://github.com/apache/flink-agents/pull/71#issuecomment-3088807364 Hi, @kitalkuyo-gita, thanks for your contribution, but there are some basic issues should be settled before we talk about the detail of this PR. 1. I think this PR is not consist

Re: [PR] [FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN [flink]

2025-07-18 Thread via GitHub
davidradl commented on code in PR #26809: URL: https://github.com/apache/flink/pull/26809#discussion_r2215570305 ## flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java: ## @@ -110,16 +110,16 @@ public class YarnConfigOptions { public static f

Re: [PR] [FLINK-38112] Align default of yarn.application-attempt-failures-validity-interval with YARN [flink]

2025-07-18 Thread via GitHub
davidradl commented on code in PR #26809: URL: https://github.com/apache/flink/pull/26809#discussion_r2215557321 ## docs/layouts/shortcodes/generated/yarn_config_configuration.html: ## @@ -28,9 +28,9 @@ yarn.application-attempt-failures-validity

Re: [PR] [FLINK-38020] Fix NPE in NonTimeRangeUnboundedFunction [flink]

2025-07-18 Thread via GitHub
fhueske commented on code in PR #26807: URL: https://github.com/apache/flink/pull/26807#discussion_r2215491597 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRangeUnboundedPrecedingFunction.java: ## @@ -422,11 +422,13 @@ pri

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

2025-07-18 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-26823] Adding Cassandra Table Source [flink-connector-cassandra]

2025-07-18 Thread via GitHub
echauchot commented on PR #35: URL: https://github.com/apache/flink-connector-cassandra/pull/35#issuecomment-3088159776 > ## Summary > This PR implements complete **Apache Flink Table/SQL API support for reading from Apache Cassandra** through a new `CassandraDynamicTableSource`. Previo

Re: [PR] [FLINK-26823] Adding Cassandra Table Source [flink-connector-cassandra]

2025-07-18 Thread via GitHub
echauchot commented on PR #35: URL: https://github.com/apache/flink-connector-cassandra/pull/35#issuecomment-3087760255 @Poorvankbhatia reviewing -- 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 t

Re: [PR] [FLINK-37914][table] Add built-in OBJECT_UPDATE function [flink]

2025-07-18 Thread via GitHub
raminqaf commented on code in PR #26806: URL: https://github.com/apache/flink/pull/26806#discussion_r2215188496 ## docs/data/sql_functions.yml: ## @@ -1219,6 +1219,35 @@ valueconstruction: - table: NUMERIC.rows description: Creates a NUMERIC interval of rows (commonly us

Re: [PR] [FLINK-37914][table] Add built-in OBJECT_UPDATE function [flink]

2025-07-18 Thread via GitHub
raminqaf commented on code in PR #26806: URL: https://github.com/apache/flink/pull/26806#discussion_r2215188496 ## docs/data/sql_functions.yml: ## @@ -1219,6 +1219,35 @@ valueconstruction: - table: NUMERIC.rows description: Creates a NUMERIC interval of rows (commonly us

Re: [PR] [FLINK-37914][table] Add built-in OBJECT_UPDATE function [flink]

2025-07-18 Thread via GitHub
raminqaf commented on code in PR #26806: URL: https://github.com/apache/flink/pull/26806#discussion_r2215188496 ## docs/data/sql_functions.yml: ## @@ -1219,6 +1219,35 @@ valueconstruction: - table: NUMERIC.rows description: Creates a NUMERIC interval of rows (commonly us