Re: [PR] [FLINK-36536] Bumped `commons-text` from 1.10.0 to 1.12.0 [flink]

2025-07-14 Thread via GitHub
github-actions[bot] commented on PR #26459: URL: https://github.com/apache/flink/pull/26459#issuecomment-3072173735 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-37672] Bump protobuf-maven-plugin [flink]

2025-07-14 Thread via GitHub
github-actions[bot] commented on PR #26464: URL: https://github.com/apache/flink/pull/26464#issuecomment-3072173812 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-38105][python] Change NamespaceAggsHandleFunctionBase.get_accumulators to cpdef [flink]

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

[jira] [Updated] (FLINK-38105) AttributeError: 'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute 'get_accumulators'

2025-07-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38105: --- Labels: pull-request-available (was: ) > AttributeError: 'pyflink.fn_execution.table.window

[PR] [FLINK-38105][python] Change NamespaceAggsHandleFunctionBase.get_accumulators to cpdef [flink]

2025-07-14 Thread via GitHub
dianfu opened a new pull request, #26798: URL: https://github.com/apache/flink/pull/26798 ## What is the purpose of the change *This pull request fixes the issue that get_accumulators could not be found during job start up. As it's called from python script, it should be declared as

[jira] [Updated] (FLINK-38105) AttributeError: 'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute 'get_accumulators'

2025-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-38105: Description: Job failover with the following exception: {code} Caused by: java.util.concurrent.ExecutionE

[jira] [Updated] (FLINK-38105) AttributeError: 'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute 'get_accumulators'

2025-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-38105: Attachment: (was: image-2025-07-15-11-43-31-134.png) > AttributeError: 'pyflink.fn_execution.table.win

[jira] [Created] (FLINK-38105) AttributeError: 'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute 'get_accumulators'

2025-07-14 Thread Dian Fu (Jira)
Dian Fu created FLINK-38105: --- Summary: AttributeError: 'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute 'get_accumulators' Key: FLINK-38105 URL: https://issues.apache.org/jira/browse/FLINK-3

[jira] [Closed] (FLINK-37775) Consolidate PyFlink development dependencies in pyproject.toml

2025-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-37775. --- Resolution: Fixed Merged to master via 232920e4fd09dc9e26d9ddfbb962c00dfdd08535 > Consolidate PyFlink devel

[jira] [Updated] (FLINK-37775) Consolidate PyFlink development dependencies in pyproject.toml

2025-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-37775: Fix Version/s: 2.2 > Consolidate PyFlink development dependencies in pyproject.toml >

Re: [PR] [FLINK-37775][python] Manage python development/test dependencies in pyproject.yaml [flink]

2025-07-14 Thread via GitHub
dianfu closed pull request #26642: [FLINK-37775][python] Manage python development/test dependencies in pyproject.yaml URL: https://github.com/apache/flink/pull/26642 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [plan][python][java] Add test cases for checking agent plan compatibi… [flink-agents]

2025-07-14 Thread via GitHub
xintongsong commented on code in PR #60: URL: https://github.com/apache/flink-agents/pull/60#discussion_r2206102961 ## e2e-test/test-scripts/test-data/placeholder.txt: ## @@ -0,0 +1,18 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor

[jira] [Resolved] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode

2025-07-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-38032. --- Resolution: Fixed > Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode >

[jira] [Updated] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin

2025-07-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-38029: -- Fix Version/s: 2.1.0 > Release Testing: Verify FLIP-486: Introduce a new DeltaJoin > -

[jira] [Commented] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode

2025-07-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005278#comment-18005278 ] dalongliu commented on FLINK-38032: --- Thanks [~au_miner], closed it. > Release Testing

[jira] [Updated] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode

2025-07-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-38032: -- Fix Version/s: 2.1.0 > Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode > ---

[jira] [Assigned] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode

2025-07-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-38032: - Assignee: Qilong Wang > Release Testing: Verify FLIP-519: Introduce async lookup key ordered mo

[jira] [Updated] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-38067: -- Fix Version/s: 2.1.0 > Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE > Implementati

[jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005277#comment-18005277 ] dalongliu commented on FLINK-38067: --- Thanks [~kartikeypant], closed it. > Release Tes

[jira] [Resolved] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-38067. --- Resolution: Fixed > Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE > Implementatio

[jira] [Closed] (FLINK-38094) Introduce pyflink.__version__

2025-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-38094. --- Resolution: Fixed > Introduce pyflink.__version__ > - > > Key: F

[jira] [Commented] (FLINK-38094) Introduce pyflink.__version__

2025-07-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005276#comment-18005276 ] Dian Fu commented on FLINK-38094: - Merged to: - master via d88138799e28b99a596c8310844be

[jira] [Commented] (FLINK-38032) Release Testing: Verify FLIP-519: Introduce async lookup key ordered mode

2025-07-14 Thread Qilong Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005275#comment-18005275 ] Qilong Wang commented on FLINK-38032: - According to my testing, the results are in l

Re: [PR] [FLINK-38094][python] Introduce pyflink.__version__ [flink]

2025-07-14 Thread via GitHub
dianfu closed pull request #26793: [FLINK-38094][python] Introduce pyflink.__version__ URL: https://github.com/apache/flink/pull/26793 -- 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 co

[jira] [Assigned] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed

2025-07-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-38098: Assignee: shilei-ly > When submitting a task with the flink run command, adding the -sae

[jira] [Commented] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed

2025-07-14 Thread shilei-ly (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005263#comment-18005263 ] shilei-ly commented on FLINK-38098: --- Hi [~xtsong] , I will fix this problem, please as

[jira] [Commented] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed

2025-07-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005262#comment-18005262 ] Xintong Song commented on FLINK-38098: -- [~shilei]  I think you're right. Thanks for

[jira] [Commented] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed

2025-07-14 Thread shilei-ly (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005261#comment-18005261 ] shilei-ly commented on FLINK-38098: --- Hi [~xtsong] ,from the code submission record, I

Re: [PR] [FLINK-38068][model] Build uber jar for open-ai model (#26770) [flink]

2025-07-14 Thread via GitHub
lihaosky commented on code in PR #26782: URL: https://github.com/apache/flink/pull/26782#discussion_r2206020925 ## flink-models/flink-model-openai/pom.xml: ## @@ -39,35 +39,62 @@ under the License. 2.11.0 + Review Comment: I have a task for

[jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-14 Thread Hao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005249#comment-18005249 ] Hao Li commented on FLINK-38067: Thanks [~kartikeypant] for testing > Release Testing:

[jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-14 Thread Hao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005248#comment-18005248 ] Hao Li commented on FLINK-38067: Yes. It requires copying the Jar manually. It can be co

[jira] [Created] (FLINK-38104) FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API

2025-07-14 Thread Hao Li (Jira)
Hao Li created FLINK-38104: -- Summary: FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Key: FLINK-38104 URL: https://issues.apache.org/jira/browse/FLINK-38104 Project: Flink Issue Type: New Feature

Re: [PR] [FLINK-38073][docs] Add documentation for the MultiJoin operator [flink]

2025-07-14 Thread via GitHub
gustavodemorais commented on PR #26775: URL: https://github.com/apache/flink/pull/26775#issuecomment-3071022862 I've answered the questions and complemented the doc. I'm currently out of office. Thanks for picking it up @raminqaf -- This is an automated message from the Apache Git Servic

Re: [PR] [FLINK-38073][docs] Add documentation for the MultiJoin operator [flink]

2025-07-14 Thread via GitHub
gustavodemorais commented on code in PR #26775: URL: https://github.com/apache/flink/pull/26775#discussion_r2205843622 ## docs/content/docs/dev/table/tuning.md: ## @@ -302,3 +302,67 @@ The execution of mini-batch join operator are as shown in the figure below. MiniBatch optimi

Re: [PR] [FLINK-38073][docs] Add documentation for the MultiJoin operator [flink]

2025-07-14 Thread via GitHub
gustavodemorais commented on code in PR #26775: URL: https://github.com/apache/flink/pull/26775#discussion_r2205842816 ## docs/content/docs/dev/table/tuning.md: ## @@ -302,3 +302,67 @@ The execution of mini-batch join operator are as shown in the figure below. MiniBatch optimi

Re: [PR] [hotfix] ELEMENT should throw TableRuntimeException [flink]

2025-07-14 Thread via GitHub
nateab commented on code in PR #26719: URL: https://github.com/apache/flink/pull/26719#discussion_r2205618947 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java: ## @@ -1879,4 +1881,17 @@ private Stream splitT

Re: [PR] Add Kafka-to-Kafka SQL Example to Documentation [flink]

2025-07-14 Thread via GitHub
Ashfaqbs commented on PR #26789: URL: https://github.com/apache/flink/pull/26789#issuecomment-3070230143 https://medium.com/@ashfaqbs/real-time-kafka-to-kafka-stream-processing-with-apache-flink-sql-c534a1d67501 -- This is an automated message from the Apache Git Service. To respond to th

[jira] [Comment Edited] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-14 Thread Kartikey Pant (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005194#comment-18005194 ] Kartikey Pant edited comment on FLINK-38067 at 7/14/25 4:24 PM: --

[jira] [Comment Edited] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-14 Thread Kartikey Pant (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005194#comment-18005194 ] Kartikey Pant edited comment on FLINK-38067 at 7/14/25 4:23 PM: --

[jira] [Comment Edited] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-14 Thread Kartikey Pant (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005194#comment-18005194 ] Kartikey Pant edited comment on FLINK-38067 at 7/14/25 4:23 PM: --

[jira] [Commented] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-14 Thread Kartikey Pant (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005194#comment-18005194 ] Kartikey Pant commented on FLINK-38067: --- Hi [~lsy] , @li, I have completed the re

[jira] [Comment Edited] (FLINK-38067) Release Testing: Verify FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-07-14 Thread Kartikey Pant (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005194#comment-18005194 ] Kartikey Pant edited comment on FLINK-38067 at 7/14/25 4:22 PM: --

[jira] (FLINK-38102) RestApiMetricsCollectorTest is unstable

2025-07-14 Thread Mahesh Sambaram (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38102 ] Mahesh Sambaram deleted comment on FLINK-38102: - was (Author: JIRAUSER309972): Hi [~rmetzger] , can i work on this, could you please guide me on this? > RestApiMetricsCollectorTest is un

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

2025-07-14 Thread via GitHub
AlanConfluent commented on PR #26567: URL: https://github.com/apache/flink/pull/26567#issuecomment-3070071468 I just did another rebase and changed the Flink version to be 2.2, since I missed 2.1 -- This is an automated message from the Apache Git Service. To respond to the message, pleas

Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-07-14 Thread via GitHub
JinkunLiu commented on PR #26196: URL: https://github.com/apache/flink/pull/26196#issuecomment-3070044729 @lihaosky could you help review this PR when you have time? Thanks a lot! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

Re: [PR] [FLINK-38103][table] Fix error for inline structured types in DataTypeFactory [flink]

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

Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-07-14 Thread via GitHub
JinkunLiu commented on PR #26196: URL: https://github.com/apache/flink/pull/26196#issuecomment-3070033113 @jnh5y Sorry to bother you, but could you please approve the English revisions when you have a moment? Thank you! -- This is an automated message from the Apache Git Service. To respo

Re: [PR] [FLINK-37701][flink-runtime] Backporting of the fix to 2.0 for AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink]

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

[jira] [Updated] (FLINK-38103) DataTypeFactory cannot restore inline structured types

2025-07-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38103: --- Labels: pull-request-available (was: ) > DataTypeFactory cannot restore inline structured t

[PR] [FLINK-38103][table] Fix error for inline structured types in DataTypeFactory [flink]

2025-07-14 Thread via GitHub
twalthr opened a new pull request, #26797: URL: https://github.com/apache/flink/pull/26797 ## What is the purpose of the change Fixes a problem in `DataTypeFactoryImpl` and structured types where the class is not in the classpath. ## Brief change log DataTypeFactoryI

Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-07-14 Thread via GitHub
JinkunLiu commented on PR #26196: URL: https://github.com/apache/flink/pull/26196#issuecomment-3070026861 Hey @xccui @wuchong @klion26, could you help review this PR when you have time? Thanks a lot! -- This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline

2025-07-14 Thread Aleksandr Iushmanov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005173#comment-18005173 ] Aleksandr Iushmanov commented on FLINK-37701: - I have added a backport PR to

[PR] [FLINK-37701][flink-runtime] Backporting of the fix to 2.0 for AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment. [flink]

2025-07-14 Thread via GitHub
Izeren opened a new pull request, #26796: URL: https://github.com/apache/flink/pull/26796 Previously merged PRs: * https://github.com/apache/flink/pull/26663 * https://github.com/apache/flink/pull/26712 # PR1 https://github.com/apache/flink/pull/26663 ## What is the purpos

[jira] [Commented] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD

2025-07-14 Thread Mate Czagany (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005166#comment-18005166 ] Mate Czagany commented on FLINK-36577: -- That's an interesting idea indeed, and a bi

[jira] [Created] (FLINK-38103) DataTypeFactory cannot restore inline structured types

2025-07-14 Thread Timo Walther (Jira)
Timo Walther created FLINK-38103: Summary: DataTypeFactory cannot restore inline structured types Key: FLINK-38103 URL: https://issues.apache.org/jira/browse/FLINK-38103 Project: Flink Issue

Re: [PR] [FLINK-32033][Kubernetes-Operator] Fix Lifecycle Status of FlinkDeployment Resource in case of MISSING/ERROR JM status [flink-kubernetes-operator]

2025-07-14 Thread via GitHub
nishita-09 commented on code in PR #997: URL: https://github.com/apache/flink-kubernetes-operator/pull/997#discussion_r2205107679 ## flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/CommonStatus.java: ## @@ -90,6 +90,28 @@ public Resou

[jira] [Commented] (FLINK-38102) RestApiMetricsCollectorTest is unstable

2025-07-14 Thread Mahesh Sambaram (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005155#comment-18005155 ] Mahesh Sambaram commented on FLINK-38102: - Hi [~rmetzger] , can i work on this,

[jira] [Resolved] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD

2025-07-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-36577. Assignee: Mate Czagany Resolution: Fixed Merged to main in https://github.com/apach

Re: [PR] [FLINK-36577] Add compatibility check for FlinkStateSnapshot [flink-kubernetes-operator]

2025-07-14 Thread via GitHub
rmetzger merged PR #991: URL: https://github.com/apache/flink-kubernetes-operator/pull/991 -- 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-unsubs

[jira] [Created] (FLINK-38102) RestApiMetricsCollectorTest is unstable

2025-07-14 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-38102: -- Summary: RestApiMetricsCollectorTest is unstable Key: FLINK-38102 URL: https://issues.apache.org/jira/browse/FLINK-38102 Project: Flink Issue Type: Bug

Re: [PR] Bump org.apache.commons:commons-lang3 from 3.3.2 to 3.18.0 [flink-connector-kafka]

2025-07-14 Thread via GitHub
dependabot[bot] closed pull request #182: Bump org.apache.commons:commons-lang3 from 3.3.2 to 3.18.0 URL: https://github.com/apache/flink-connector-kafka/pull/182 -- 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] Bump org.apache.commons:commons-lang3 from 3.3.2 to 3.18.0 [flink-connector-kafka]

2025-07-14 Thread via GitHub
dependabot[bot] commented on PR #182: URL: https://github.com/apache/flink-connector-kafka/pull/182#issuecomment-3069736575 Looks like org.apache.commons:commons-lang3 is up-to-date now, so this is no longer needed. -- This is an automated message from the Apache Git Service. To respond

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

2025-07-14 Thread Thomas Cooper (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Cooper resolved FLINK-38063. --- Resolution: Fixed > Update dependencies in the Flink Connector Kafka Project > -

Re: [PR] [FLINK-38063] Update dependencies [flink-connector-kafka]

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

Re: [PR] [FLINK-38063] Update dependencies [flink-connector-kafka]

2025-07-14 Thread via GitHub
fapaul commented on code in PR #181: URL: https://github.com/apache/flink-connector-kafka/pull/181#discussion_r2205011837 ## flink-connector-kafka/pom.xml: ## @@ -239,7 +239,6 @@ under the License. org.yaml snakey

Re: [PR] [FLINK-38063] Update dependencies [flink-connector-kafka]

2025-07-14 Thread via GitHub
fapaul commented on code in PR #181: URL: https://github.com/apache/flink-connector-kafka/pull/181#discussion_r2205011837 ## flink-connector-kafka/pom.xml: ## @@ -239,7 +239,6 @@ under the License. org.yaml snakey

[jira] [Updated] (FLINK-38101) Support SI Format for CPU resources

2025-07-14 Thread Santwana Verma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Santwana Verma updated FLINK-38101: --- Description: The Kubernetes API (for example, {{{}Pod.spec.containers.resources.limits.cpu{

[jira] [Updated] (FLINK-38100) Add BigQuery catalog support for iceberg pipeline sink connector

2025-07-14 Thread Luca Occhipinti (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luca Occhipinti updated FLINK-38100: Description: With the recent release of BigQuery Metastore support for Iceberg tables, thi

[jira] [Created] (FLINK-38101) Support SI Format for CPU resources

2025-07-14 Thread Santwana Verma (Jira)
Santwana Verma created FLINK-38101: -- Summary: Support SI Format for CPU resources Key: FLINK-38101 URL: https://issues.apache.org/jira/browse/FLINK-38101 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-38100) Add BigQuery catalog support for iceberg pipeline sink connector

2025-07-14 Thread Luca Occhipinti (Jira)
Luca Occhipinti created FLINK-38100: --- Summary: Add BigQuery catalog support for iceberg pipeline sink connector Key: FLINK-38100 URL: https://issues.apache.org/jira/browse/FLINK-38100 Project: Flink

[jira] [Resolved] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator

2025-07-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-38097. Fix Version/s: kubernetes-operator-1.13.0 Assignee: Kumar Mallikarjuna Reso

Re: [PR] [FLINK-38097][docs] Add deployments/finalizers to RBAC permissions in documentation [flink-kubernetes-operator]

2025-07-14 Thread via GitHub
rmetzger merged PR #998: URL: https://github.com/apache/flink-kubernetes-operator/pull/998 -- 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-unsubs

[jira] [Closed] (FLINK-38090) TableResult.collect() returns incorrect SQL inline structured types

2025-07-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-38090. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 03530b6085deb016a6dbca9b92825cc

Re: [PR] [FLINK-38090][table] Align data type of inline structured types for TableResult.collect() [flink]

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

Re: [PR] [FLINK-37913][table] Add built-in OBJECT_OF function [flink]

2025-07-14 Thread via GitHub
raminqaf commented on code in PR #26704: URL: https://github.com/apache/flink/pull/26704#discussion_r2204913126 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ObjectOfInputTypeStrategy.java: ## @@ -0,0 +1,162 @@ +/* + * Licensed

Re: [PR] [FLINK-38073][docs] Add documentation for the MultiJoin operator [flink]

2025-07-14 Thread via GitHub
raminqaf commented on code in PR #26775: URL: https://github.com/apache/flink/pull/26775#discussion_r2204910024 ## docs/content/docs/dev/table/tuning.md: ## @@ -302,3 +302,67 @@ The execution of mini-batch join operator are as shown in the figure below. MiniBatch optimization

[jira] [Created] (FLINK-38099) Greenplum: Distribution column updates in Greenplum upsert

2025-07-14 Thread zm999999 (Jira)
zm99 created FLINK-38099: Summary: Greenplum: Distribution column updates in Greenplum upsert Key: FLINK-38099 URL: https://issues.apache.org/jira/browse/FLINK-38099 Project: Flink Issue Ty

Re: [PR] [FLINK-32033][Kubernetes-Operator] Fix Lifecycle Status of FlinkDeployment Resource in case of MISSING/ERROR JM status [flink-kubernetes-operator]

2025-07-14 Thread via GitHub
gyfora commented on code in PR #997: URL: https://github.com/apache/flink-kubernetes-operator/pull/997#discussion_r2204761797 ## flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/CommonStatus.java: ## @@ -90,6 +90,28 @@ public ResourceL

Re: [PR] [FLINK-32033][Kubernetes-Operator] Fix Lifecycle Status of FlinkDeployment Resource in case of MISSING/ERROR JM status [flink-kubernetes-operator]

2025-07-14 Thread via GitHub
nishita-09 commented on code in PR #997: URL: https://github.com/apache/flink-kubernetes-operator/pull/997#discussion_r2204738669 ## flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/CommonStatus.java: ## @@ -90,6 +90,28 @@ public Resou

Re: [PR] [BP-1.20][FLINK-38082][datastream] Avoid unexpected retries when user async function invokes completeExceptionally #26790 [flink]

2025-07-14 Thread via GitHub
lincoln-lil commented on PR #26791: URL: https://github.com/apache/flink/pull/26791#issuecomment-3069231002 @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 comme

[jira] [Commented] (FLINK-38083) OBJECT_OF function's type don't get inferred correctly during comparison

2025-07-14 Thread Mahesh Sambaram (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005101#comment-18005101 ] Mahesh Sambaram commented on FLINK-38083: - Hi [~raminqaf], can i work on this, c

[jira] [Commented] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed

2025-07-14 Thread shilei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005105#comment-18005105 ] shilei commented on FLINK-38098: The constructor of the JobClientHeartbeatRequestBody cl

[jira] [Updated] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed

2025-07-14 Thread shilei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shilei updated FLINK-38098: --- Attachment: image-2025-07-14-19-36-16-653.png > When submitting a task with the flink run command, adding th

[jira] [Created] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed

2025-07-14 Thread shilei (Jira)
shilei created FLINK-38098: -- Summary: When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed Key: FLINK-38098 URL: https://issues.apache.org/jira/browse/FLINK-38098

[jira] [Commented] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed

2025-07-14 Thread shilei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005103#comment-18005103 ] shilei commented on FLINK-38098: I have found the cause of the problem, which is due to

Re: [PR] [FLINK-38090][table] Align data type of inline structured types for TableResult.collect() [flink]

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

[PR] [FLINK-38097][docs] Add deployments/finalizers to RBAC permissions in documentation [flink-kubernetes-operator]

2025-07-14 Thread via GitHub
kumar-mallikarjuna opened a new pull request, #998: URL: https://github.com/apache/flink-kubernetes-operator/pull/998 ## What is the purpose of the change Adds deployments/finalizers to RBAC permissions in documentation section Cluster Scoped Flink Operator With Jobs Running i

[jira] [Updated] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator

2025-07-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38097: --- Labels: documentaion pull-request-available (was: documentaion) > Add finalizer to custom R

[PR] [FLINK-38090][table] Align data type of inline structured types for TableResult.collect() [flink]

2025-07-14 Thread via GitHub
twalthr opened a new pull request, #26795: URL: https://github.com/apache/flink/pull/26795 ## What is the purpose of the change Backport of #26784 for `release-2.1` branch. ## Brief change log N/A ## Verifying this change N/A ## Does this pull request

Re: [PR] [FLINK-28648][Kubernetes Operator] Allow session deletion to block on any running job [flink-kubernetes-operator]

2025-07-14 Thread via GitHub
nishita-09 commented on PR #994: URL: https://github.com/apache/flink-kubernetes-operator/pull/994#issuecomment-3068976716 @gyfora I ran these tests on my local, they seem to be passing. I am not sure what is causing the issue here. Can you have a look at it if possible? -- This is an au

[jira] [Updated] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator

2025-07-14 Thread Kumar Mallikarjuna (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kumar Mallikarjuna updated FLINK-38097: --- Issue Type: Bug (was: Improvement) > Add finalizer to custom Role example for Clust

[jira] [Updated] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator

2025-07-14 Thread Kumar Mallikarjuna (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kumar Mallikarjuna updated FLINK-38097: --- Description: The documentation for cluster-scoped operator ([https://nightlies.apac

[jira] [Updated] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy

2025-07-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-38096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Misiewicz updated FLINK-38096: - Description: [AsyncSinkWriter|https://github.com/apache/flink/blob/master/flink-connecto

[jira] [Updated] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy

2025-07-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-38096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Misiewicz updated FLINK-38096: - Description: [AsyncSinkWriter|https://github.com/apache/flink/blob/master/flink-connecto

[jira] [Created] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator

2025-07-14 Thread Kumar Mallikarjuna (Jira)
Kumar Mallikarjuna created FLINK-38097: -- Summary: Add finalizer to custom Role example for Cluster Scoped Flink Operator Key: FLINK-38097 URL: https://issues.apache.org/jira/browse/FLINK-38097 Pr

[jira] [Updated] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy

2025-07-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-38096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Misiewicz updated FLINK-38096: - Description: [AsyncSinkWriter|https://github.com/apache/flink/blob/master/flink-connecto

[jira] [Updated] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy

2025-07-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-38096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Misiewicz updated FLINK-38096: - Description: [AsyncSinkWriter|https://github.com/apache/flink/blob/master/flink-connecto

[jira] [Updated] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy

2025-07-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-38096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Misiewicz updated FLINK-38096: - Description: [AsyncSinkWriter|https://github.com/apache/flink/blob/master/flink-connecto

[jira] [Created] (FLINK-38096) AsyncSinkWriter may hang when configured with a custom rate limiting strategy

2025-07-14 Thread Jira
Michał Misiewicz created FLINK-38096: Summary: AsyncSinkWriter may hang when configured with a custom rate limiting strategy Key: FLINK-38096 URL: https://issues.apache.org/jira/browse/FLINK-38096

Re: [PR] [FLINK-38090][table] Align data type of inline structured types for TableResult.collect() [flink]

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

  1   2   >