[jira] [Created] (FLINK-37133) Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s

2025-01-14 Thread Feng Jin (Jira)
Feng Jin created FLINK-37133: Summary: Support Submitting Refresh Tasks of Materialized Table to Yarn/K8s Key: FLINK-37133 URL: https://issues.apache.org/jira/browse/FLINK-37133 Project: Flink I

Re: Stale PR Action running but the labels are missing

2025-01-14 Thread Rui Fan
It seems the stale label works for now. 124 PRs[1] were labeled as 'stale' in the fourth batch[2]. [1] https://github.com/apache/flink/labels/stale?page=5&q=is%3Aopen+label%3Astale [2] https://github.com/apache/flink/actions/runs/12782496848 Best, Rui On Wed, Jan 15, 2025 at 10:09 AM Rui Fan <19

[jira] [Created] (FLINK-37132) Add schema validation in Multi Transform

2025-01-14 Thread MOBIN (Jira)
MOBIN created FLINK-37132: - Summary: Add schema validation in Multi Transform Key: FLINK-37132 URL: https://issues.apache.org/jira/browse/FLINK-37132 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-37131) checkpoint tolerable-failed invalid

2025-01-14 Thread altenchen (Jira)
altenchen created FLINK-37131: - Summary: checkpoint tolerable-failed invalid Key: FLINK-37131 URL: https://issues.apache.org/jira/browse/FLINK-37131 Project: Flink Issue Type: Bug Compo

Re:Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join

2025-01-14 Thread Xuyang
LGTM overall. Thanks for updating. I have no problem and +1 for this feature. -- Best! Xuyang 在 2025-01-15 12:33:16,"Weiqing Yang" 写道: >Hi Xuyang, > >Thank you for your detailed feedback! I’ve updated the proposal doc >accordingly. Please feel free to take another look and let me

Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join

2025-01-14 Thread Weiqing Yang
Hi Xuyang, Thank you for your detailed feedback! I’ve updated the proposal doc accordingly. Please feel free to take another look and let me know if you have any further thoughts or suggestions. Best regards, Weiqing On Mon, Jan 13, 2025 at 3:50 AM Xuyang wrote: > Hi, Weiqing. > > After readin

[jira] [Created] (FLINK-37130) Provide a util converting future of StateIterator to Iterable

2025-01-14 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-37130: --- Summary: Provide a util converting future of StateIterator to Iterable Key: FLINK-37130 URL: https://issues.apache.org/jira/browse/FLINK-37130 Project: Flink

Re: StreamingFilSink with FlinkRunner

2025-01-14 Thread Taher Koitawala
Adding Flink community here just incase anyone has more info on this. On Tue, 14 Jan 2025 at 1:00 PM, Taher Koitawala wrote: > Hi All, > Been moving from Flink development to Beam development i want am > using FileIO parquet Io. > > Folks in Flink we could use streaming flink sink with

[jira] [Created] (FLINK-37129) AbstractSqlGatewayStatementITCaseBase.testFlinkSqlStatements failed on AZP

2025-01-14 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-37129: -- Summary: AbstractSqlGatewayStatementITCaseBase.testFlinkSqlStatements failed on AZP Key: FLINK-37129 URL: https://issues.apache.org/jira/browse/FLINK-37129 Project: Flink

[jira] [Created] (FLINK-37128) Skip binlog replay filter when skip backfill

2025-01-14 Thread JunboWang (Jira)
JunboWang created FLINK-37128: - Summary: Skip binlog replay filter when skip backfill Key: FLINK-37128 URL: https://issues.apache.org/jira/browse/FLINK-37128 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-37127) BuiltInAggregateFunctionTestBase failed on AZP

2025-01-14 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-37127: -- Summary: BuiltInAggregateFunctionTestBase failed on AZP Key: FLINK-37127 URL: https://issues.apache.org/jira/browse/FLINK-37127 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37126) Add Validator for Autoscler

2025-01-14 Thread yuanfenghu (Jira)
yuanfenghu created FLINK-37126: -- Summary: Add Validator for Autoscler Key: FLINK-37126 URL: https://issues.apache.org/jira/browse/FLINK-37126 Project: Flink Issue Type: Improvement Com

退订

2025-01-14 Thread cun8cun8
退订

退订

2025-01-14 Thread 王飞
退订

Re: Stale PR Action running but the labels are missing

2025-01-14 Thread Rui Fan
Hi Tom, Thanks for following up and pointing it out! I just asked ChatGPT, it seems github bot doesn't create new labels and we need to create new labels in advance. I created 'stale' and 'closed-stale' label[1]s just now, let us see whether the label works for subsequent PRs. [1] https://githu

[jira] [Created] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException

2025-01-14 Thread sehaj pal singh sandhu (Jira)
sehaj pal singh sandhu created FLINK-37125: -- Summary: env.log.max Log4j java.lang.NumberFormatException Key: FLINK-37125 URL: https://issues.apache.org/jira/browse/FLINK-37125 Project: Flink

Stale PR Action running but the labels are missing

2025-01-14 Thread Tom Cooper
Hi all, We have enabled [1] the Stale PR GitHub action and it has starting tagging PRs [2] with the specified comments (for example [3]). However, it is not applying the specified 'stale' label to the PRs. The docs don't say anything about needing to create the label first, but I wondered if

Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 2 (with Coordination)

2025-01-14 Thread Sergio Chong Loo
FLIP-504: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=337677650 - Sergio > On Jan 13, 2025, at 3:16 PM, Sergio Chong Loo wrote: > > Hi folks, > > As mentioned in [1], this FLIP represents the 2nd phase to add Blue/Green > deployments support. > > This phase adds the ca

Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)

2025-01-14 Thread Sergio Chong Loo
FLIP-503: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=337677648 - Sergio > On Jan 13, 2025, at 2:39 PM, Sergio Chong Loo wrote: > > Hi folks, > > As proposed in [1] we would like to more formally continue the discussion to > add Blue/Green deployments support to Flink v

[jira] [Created] (FLINK-37124) Simplify the print log in Flink CDC schema Coordinator

2025-01-14 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-37124: -- Summary: Simplify the print log in Flink CDC schema Coordinator Key: FLINK-37124 URL: https://issues.apache.org/jira/browse/FLINK-37124 Project: Flink Issue Type

Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support

2025-01-14 Thread Timo Walther
Hi Alan, thanks for giving us some context. It looks like FLIP-313 has not seen any progress for 2 years. We can still revive FLIP-313 for the hint discussion but start with config options. It makes sense that there is consistency between AsycScalarFunction and AsyncTableFunction with respect

[jira] [Created] (FLINK-37123) FlinkCDC YAML supports TIMESTAMP_TZ

2025-01-14 Thread Wenkai Qi (Jira)
Wenkai Qi created FLINK-37123: - Summary: FlinkCDC YAML supports TIMESTAMP_TZ Key: FLINK-37123 URL: https://issues.apache.org/jira/browse/FLINK-37123 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-37121) Fix syntax and examples in create table statement doc

2025-01-14 Thread Mingcan Wang (Jira)
Mingcan Wang created FLINK-37121: Summary: Fix syntax and examples in create table statement doc Key: FLINK-37121 URL: https://issues.apache.org/jira/browse/FLINK-37121 Project: Flink Issue T

[jira] [Created] (FLINK-37122) NoSuchMethodError occurs when using flink 1.18.1.

2025-01-14 Thread ChaomingZhang (Jira)
ChaomingZhang created FLINK-37122: - Summary: NoSuchMethodError occurs when using flink 1.18.1. Key: FLINK-37122 URL: https://issues.apache.org/jira/browse/FLINK-37122 Project: Flink Issue Typ

Re: [DISCUSSION] flink-connector-hive first release of externalized connector

2025-01-14 Thread Yanquan Lv
+1. Thanks for restarting this release plan. Best, Yanquan. > 2025年1月14日 06:15,Sergey Nuyanzin 写道: > > Hi everyone, > > This is yet another iteration to request/propose release of external Hive > connector. > Unfortunately the first attempt (about a year ago[1]) was not able to > attract enoug

[jira] [Created] (FLINK-37120) MySqlSnapshotSplitAssigner assign the enging chunk early to avoid TaskManager OOM

2025-01-14 Thread JunboWang (Jira)
JunboWang created FLINK-37120: - Summary: MySqlSnapshotSplitAssigner assign the enging chunk early to avoid TaskManager OOM Key: FLINK-37120 URL: https://issues.apache.org/jira/browse/FLINK-37120 Project:

[jira] [Created] (FLINK-37119) Bump the version of Paimon flink to 1.0.0

2025-01-14 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-37119: -- Summary: Bump the version of Paimon flink to 1.0.0 Key: FLINK-37119 URL: https://issues.apache.org/jira/browse/FLINK-37119 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-37118) Enhance flink cdc metrics

2025-01-14 Thread melin (Jira)
melin created FLINK-37118: - Summary: Enhance flink cdc metrics Key: FLINK-37118 URL: https://issues.apache.org/jira/browse/FLINK-37118 Project: Flink Issue Type: New Feature Components: Fli

[jira] [Created] (FLINK-37117) Add docs for async state SQL operator in 2.0

2025-01-14 Thread xuyang (Jira)
xuyang created FLINK-37117: -- Summary: Add docs for async state SQL operator in 2.0 Key: FLINK-37117 URL: https://issues.apache.org/jira/browse/FLINK-37117 Project: Flink Issue Type: Sub-task