[jira] [Created] (FLINK-37227) Support Reuse Multiple Table Sinks in Planner

2025-01-26 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-37227: Summary: Support Reuse Multiple Table Sinks in Planner Key: FLINK-37227 URL: https://issues.apache.org/jira/browse/FLINK-37227 Project: Flink Issue Type: Imp

[jira] [Updated] (FLINK-37227) Support Reuse Multiple Table Sinks in Planner

2025-01-26 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-37227: - Description: When users are trying to partial-update a downstream table from multiple source ta

Re: [PR] [FLINK-27550] The method of checkYarnQueues is compatible with capacity scheduler [flink]

2025-01-26 Thread via GitHub
zuston closed pull request #19675: [FLINK-27550] The method of checkYarnQueues is compatible with capacity scheduler URL: https://github.com/apache/flink/pull/19675 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-25410] Flink CLI should exit when app is accepted with detach … [flink]

2025-01-26 Thread via GitHub
zuston closed pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach … URL: https://github.com/apache/flink/pull/18220 -- 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

[jira] [Updated] (FLINK-37227) FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-01-26 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-37227: - Summary: FLIP-506: Support Reuse Multiple Table Sinks in Planner (was: Support Reuse Multiple T

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

2025-01-26 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-36696. - Resolution: Fixed Merged to main(1.11.0) via: d5d027e4bd7752b08043f8aa196f7a20c7afeda0 > JDBC Autoscale

Re: [PR] [FLINK-35512][flink-clients] Don't depend on the flink-clients jar actually existing. [flink]

2025-01-26 Thread via GitHub
SamBarker commented on PR #24931: URL: https://github.com/apache/flink/pull/24931#issuecomment-2614592255 Thanks @ferenc-csaky I didn't manage to find the time while travelling with the family to make the changes -- This is an automated message from the Apache Git Service. To respond to t

[jira] [Updated] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads

2025-01-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37220: --- Labels: pull-request-available (was: ) > GuavaRateLimiter creates an ExecutorService withou

[PR] [FLINK-37220][connector-api] Deprecates RateLimiterStrategy#perSecond and introduces PerSecondRateLimiterStrategy to fix thread leakage and intro [flink]

2025-01-26 Thread via GitHub
XComp opened a new pull request, #26084: URL: https://github.com/apache/flink/pull/26084 ## What is the purpose of the change The old approach didn't clean up the internally used `ExecutorService` which leaks a thread. ## Brief change log * Removes `GuavaRateLimiter`

Re: [PR] [FLINK-37220][connector-api] Deprecates RateLimiterStrategy#perSecond and introduces PerSecondRateLimiterStrategy to fix thread leakage and intro [flink]

2025-01-26 Thread via GitHub
flinkbot commented on PR #26084: URL: https://github.com/apache/flink/pull/26084#issuecomment-2614408121 ## CI report: * 8ad1409f66a79a0a70926cfc71e66334b7c79386 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37206][Runtime] Fix initialization of batching timer service in async state operators [flink]

2025-01-26 Thread via GitHub
Zakelly commented on PR #26071: URL: https://github.com/apache/flink/pull/26071#issuecomment-2614508206 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

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

2025-01-26 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-37222: Priority: Blocker (was: Major) > Table planner exception when sql client submit job > ---

[jira] [Assigned] (FLINK-32033) Resource lifecycle state shows stable even if application deployment goes missing

2025-01-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-32033: -- Assignee: (was: Clara Xiong) > Resource lifecycle state shows stable even if application

[jira] [Assigned] (FLINK-31406) Do not delete jobgraph on scale only last-state upgrades

2025-01-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-31406: -- Assignee: (was: Nicholas Jiang) > Do not delete jobgraph on scale only last-state upgrade

[jira] [Assigned] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

2025-01-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30680: -- Assignee: (was: Matt Wang) > Consider using the autoscaler to detect slow taskmanagers >

[jira] [Created] (FLINK-37229) Add DELETING/DELETED lifecycle states

2025-01-26 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-37229: -- Summary: Add DELETING/DELETED lifecycle states Key: FLINK-37229 URL: https://issues.apache.org/jira/browse/FLINK-37229 Project: Flink Issue Type: Bug C

[jira] [Assigned] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads

2025-01-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37220: - Assignee: Matthias Pohl > GuavaRateLimiter creates an ExecutorService without shutting

[jira] [Commented] (FLINK-37098) Can not select time attribute from a view

2025-01-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17921143#comment-17921143 ] Alexander Fedulov commented on FLINK-37098: --- [~dwysakowicz] unfortunately the

[jira] [Updated] (FLINK-37098) Can not select time attribute from a view

2025-01-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-37098: -- Fix Version/s: 1.20.1 (was: 1.20.2) > Can not select time attri

[jira] [Updated] (FLINK-37098) Can not select time attribute from a view

2025-01-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-37098: -- Affects Version/s: 1.20.1 (was: 1.20.0) > Can not select ti

[jira] [Updated] (FLINK-37098) Can not select time attribute from a view

2025-01-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-37098: -- Fix Version/s: 1.20.2 (was: 1.20.1) > Can not select time attri

[jira] [Updated] (FLINK-37098) Can not select time attribute from a view

2025-01-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-37098: -- Fix Version/s: 1.20.1 (was: 1.20.2) > Can not select time attri

[jira] [Updated] (FLINK-37098) Can not select time attribute from a view

2025-01-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-37098: -- Affects Version/s: 1.20.0 (was: 1.20.1) > Can not select ti

[jira] [Updated] (FLINK-37098) Can not select time attribute from a view

2025-01-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-37098: -- Fix Version/s: 1.20.2 (was: 1.20.1) > Can not select time attri

Re: [PR] [FLINK-36696] [flink-autoscaler-plugin-jdbc] Switch sql connection usages to datasource [flink-kubernetes-operator]

2025-01-26 Thread via GitHub
1996fanrui merged PR #929: URL: https://github.com/apache/flink-kubernetes-operator/pull/929 -- 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-unsu

[jira] [Created] (FLINK-37228) kubernetes HA fails both on flink 1.19.1 and flink 1.20

2025-01-26 Thread sigalit (Jira)
sigalit created FLINK-37228: --- Summary: kubernetes HA fails both on flink 1.19.1 and flink 1.20 Key: FLINK-37228 URL: https://issues.apache.org/jira/browse/FLINK-37228 Project: Flink Issue Type: Bu

[PR] [hotfix][runtime] Remove the redundant JobVertex#hasNoConnectedInputs and use JobVertex#isInputVertex instead. [flink]

2025-01-26 Thread via GitHub
RocMarshal opened a new pull request, #26083: URL: https://github.com/apache/flink/pull/26083 ## What is the purpose of the change Remove the redundant JobVertex#hasNoConnectedInputs and use JobVertex#isInputVertex instead. ## Brief change log Remove the

Re: [PR] [FLINK-37223] Add the missing documents and parameters of MySQL CDC. [flink-cdc]

2025-01-26 Thread via GitHub
lvyanquan commented on code in PR #3894: URL: https://github.com/apache/flink-cdc/pull/3894#discussion_r1929687870 ## docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md: ## @@ -422,6 +434,11 @@ Flink SQL> SELECT * FROM orders; TIMESTAMP_LTZ(3) NOT NULL 当前记录

Re: [PR] [hotfix][runtime] Remove the redundant JobVertex#hasNoConnectedInputs and use JobVertex#isInputVertex instead. [flink]

2025-01-26 Thread via GitHub
flinkbot commented on PR #26083: URL: https://github.com/apache/flink/pull/26083#issuecomment-2614270031 ## CI report: * 2d5d25e9312df25595cfdd68c26a92cb0826825f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`