[jira] [Created] (FLINK-32709) Modify segment size to improve memory utilization for Hybrid Shuffle

2023-07-27 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-32709: - Summary: Modify segment size to improve memory utilization for Hybrid Shuffle Key: FLINK-32709 URL: https://issues.apache.org/jira/browse/FLINK-32709 Project: Flink

[jira] [Created] (FLINK-32708) Fix the write logic in remote tier of hybrid shuffle

2023-07-27 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-32708: --- Summary: Fix the write logic in remote tier of hybrid shuffle Key: FLINK-32708 URL: https://issues.apache.org/jira/browse/FLINK-32708 Project: Flink Issue

[jira] [Created] (FLINK-32707) the timestamp field precision should be set to 0 instead of 1

2023-07-27 Thread liangjj (Jira)
liangjj created FLINK-32707: --- Summary: the timestamp field precision should be set to 0 instead of 1 Key: FLINK-32707 URL: https://issues.apache.org/jira/browse/FLINK-32707 Project: Flink Issue

Re: [DISCUSS] FLIP-348: Support System Columns in SQL and Table API

2023-07-27 Thread Alexey Leonov-Vendrovskiy
> > `SELECT * FROM (SELECT $rowtime, * FROM t);` > Am I right that it will show `$rowtime` in output ? Yes, all explicitly selected columns become a part of the result (and intermediate) schema, and hence propagate. On Thu, Jul 27, 2023 at 2:40 PM Alexey Leonov-Vendrovskiy <

Metrics are not reported in Python UDF (used inside FlinkSQL) when exception is raised

2023-07-27 Thread Elkhan Dadashov
Hi Flinkers, Wanted to check if anyone else has faced this issue before: When Python UDF (which is used inside FlinkSQL) raises an exception, then metrics get lost and not reported. Facing this issue both in Flink 1.16.2 and FLink 1.17.1 (Python 3.9). If an exception is not raised, then metrics

Re: [DISCUSS] FLIP-348: Support System Columns in SQL and Table API

2023-07-27 Thread Alexey Leonov-Vendrovskiy
Thank you, Timo, for starting this FLIP! I propose the following change: Remove the requirement that DESCRIBE need to show system columns. Some concrete vendor specific catalog implementations might prefer this approach. Usually the same system columns are available on all (or family) of

[jira] [Created] (FLINK-32706) Add SPLIT(STRING) support in SQL & Table API

2023-07-27 Thread Hanyu Zheng (Jira)
Hanyu Zheng created FLINK-32706: --- Summary: Add SPLIT(STRING) support in SQL & Table API Key: FLINK-32706 URL: https://issues.apache.org/jira/browse/FLINK-32706 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-326: Enhance Watermark to Support Processing-Time Temporal Join

2023-07-27 Thread Jing Ge
Hi Dong, Thanks for your proposal. It is a very interesting feature and also a complex one. Especially the "shotgun surgery"[1] of handling the useProcessingTime logic. While reading the FLIP, I was wondering if it possible to leverage the Visitor design pattern(not exactly use the pattern

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

2023-07-27 Thread Jing Ge
Hi Konstantin, What you said makes sense. Dropping modules is an efficient option to accelerate Flink evolution with acceptable function regressions. We should do it constantly and strategically. On the other hand, we should point out the core modules that must be backward compatible when a new

[VOTE] Apache Flink Kubernetes Operator Release 1.6.0, release candidate #1

2023-07-27 Thread Gyula Fóra
Hi Everyone, Please review and vote on the release candidate #1 for the version 1.6.0 of Apache Flink Kubernetes Operator, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Release Overview** As an overview, the release consists of

[jira] [Created] (FLINK-32705) Remove the beta for watermark alignment

2023-07-27 Thread Rui Fan (Jira)
Rui Fan created FLINK-32705: --- Summary: Remove the beta for watermark alignment Key: FLINK-32705 URL: https://issues.apache.org/jira/browse/FLINK-32705 Project: Flink Issue Type: Sub-task

Re: Remove me from your mailing list

2023-07-27 Thread Martijn Visser
Hi Divya, You'll need to send an email to dev-unsubscr...@flink.apache.org in order to be unsubscribed. Best regards, Martijn On Thu, Jul 27, 2023 at 2:18 PM Divya Sanghi wrote: > Please remove me from your mailing list as don't want to receive emails > > > Regards > Divya >

Remove me from your mailing list

2023-07-27 Thread Divya Sanghi
Please remove me from your mailing list as don't want to receive emails Regards Divya

[jira] [Created] (FLINK-32704) Supports spilling to disk when feedback channel memory buffer is full

2023-07-27 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-32704: - Summary: Supports spilling to disk when feedback channel memory buffer is full Key: FLINK-32704 URL: https://issues.apache.org/jira/browse/FLINK-32704 Project: Flink

[jira] [Created] (FLINK-32703) [hotfix] flink-python POM has a typo for protobuf-java in shading config

2023-07-27 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-32703: --- Summary: [hotfix] flink-python POM has a typo for protobuf-java in shading config Key: FLINK-32703 URL: https://issues.apache.org/jira/browse/FLINK-32703

Re: [DISCUSS] FLIP-348: Support System Columns in SQL and Table API

2023-07-27 Thread Sergey Nuyanzin
Hi Timo, Thanks for the FLIP. I also tend to think that Option 3 is better. I would be also interested in a question mentioned by Benchao Li. And a similar question about nested queries like `SELECT * FROM (SELECT $rowtime, * FROM t);` Am I right that it will show `$rowtime` in output ? On

[jira] [Created] (FLINK-32702) streaming examples could not run

2023-07-27 Thread Weihua Hu (Jira)
Weihua Hu created FLINK-32702: - Summary: streaming examples could not run Key: FLINK-32702 URL: https://issues.apache.org/jira/browse/FLINK-32702 Project: Flink Issue Type: Bug

[RESULT][VOTE] Release 2.0 must-have work items - Round 2

2023-07-27 Thread Xintong Song
Hi devs, I'm glad to announce that the must-have work items for release 2.0 [1] have been approved. The voting thread is [2] and the discussions can be found in [3][4]. There are 11 approving votes, 7 of which are binding: - Xintong Song (binding) - Yuan Mei (binding) - Yu Li (binding) - Leonard

Re: [VOTE] Release 2.0 must-have work items - Round 2

2023-07-27 Thread Xintong Song
Thanks all for participating. I'm closing this vote in another thread. Best, Xintong On Thu, Jul 27, 2023 at 11:37 AM Jiabao Sun wrote: > + 1 (non-binding) > > Thanks Xintong for driving this. > > Best, > Jiabao > > > On 2023/07/20 09:22:46 Xintong Song wrote: > > Hi all, > > > > I'd like

[jira] [Created] (FLINK-32701) Potential Memory Leak in Flink CEP due to Persistent Starting States in NFAState

2023-07-27 Thread Puneet Duggal (Jira)
Puneet Duggal created FLINK-32701: - Summary: Potential Memory Leak in Flink CEP due to Persistent Starting States in NFAState Key: FLINK-32701 URL: https://issues.apache.org/jira/browse/FLINK-32701

[jira] [Created] (FLINK-32700) Support job drain for Savepoint upgrade mode jobs in Flink Operator

2023-07-27 Thread Manan Mangal (Jira)
Manan Mangal created FLINK-32700: Summary: Support job drain for Savepoint upgrade mode jobs in Flink Operator Key: FLINK-32700 URL: https://issues.apache.org/jira/browse/FLINK-32700 Project: Flink

Re: [VOTE][2.0] FLIP-347: Remove IOReadableWritable serialization in Path

2023-07-27 Thread liu ron
+1 Best, Ron Jing Ge 于2023年7月26日周三 23:39写道: > +1(binding). > > Theoretically, I agree with Matthias. But in the practices, afaic, those > touched classes are low level APIs. We'd better have enough time to > evaluate them with care. More time might be needed than we could have > before the