[jira] [Created] (FLINK-28700) Table store sink fails to commit for Flink 1.14 batch job

2022-07-26 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-28700: --- Summary: Table store sink fails to commit for Flink 1.14 batch job Key: FLINK-28700 URL: https://issues.apache.org/jira/browse/FLINK-28700 Project: Flink

Re: [VOTE] FLIP-248: Introduce dynamic partition pruning

2022-07-26 Thread Yun Gao
+1 (binding) Thanks for proposing the FLIP! Best, Yun Gao -- From:Jing Ge Send Time:2022 Jul. 27 (Wed.) 03:40 To:undefined Subject:Re: [VOTE] FLIP-248: Introduce dynamic partition pruning +1 Thanks for driving this! On Tue,

RE: [VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal

2022-07-26 Thread wiliam sq
+1 On 2022/07/25 01:37:56 bo zhaobo wrote: > Hi all, > > Thank you very much for all feedback after the discussion in [2][3]. > Now I'd like to proceed with the vote for FLIP-250 [1], as no more > objections > or issues were raised in ML thread [2][3]. > > The vote will be opened until July 28th

[jira] [Created] (FLINK-28699) Native rocksdb full snapshot in non-incremental checkpointing

2022-07-26 Thread Lihe Ma (Jira)
Lihe Ma created FLINK-28699: --- Summary: Native rocksdb full snapshot in non-incremental checkpointing Key: FLINK-28699 URL: https://issues.apache.org/jira/browse/FLINK-28699 Project: Flink Issue

[jira] [Created] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

2022-07-26 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-28698: -- Summary: The display order of aggregated metrics should follow the order of task state transitions Key: FLINK-28698 URL: https://issues.apache.org/jira/browse/FLINK-28698

Re: [VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal

2022-07-26 Thread MrL
+1 (non-binding) > 2022年7月27日 09:18，William Wang 写道： > > +1 (non-binding) > > bo zhaobo 于2022年7月25日周一 09:38写道： > >> Hi all, >> >> Thank you very much for all feedback after the discussion in [2][3]. >> Now I'd like to proceed with the vote for FLIP-250 [1], as no more >> objections >> or

Re: [DISCUSS] FLIP-217 Support watermark alignment of source splits

2022-07-26 Thread Thomas Weise
Hi Sebastian, Thank you for updating the FLIP page. It looks good and I think you can start a VOTE. Thomas On Tue, Jul 26, 2022 at 10:57 AM Sebastian Mattheis wrote: > > Hi everybody, > > I have updated FLIP-217 [1] and have implemented the respective changes in > [2]. Please review. If there

Re: [VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal

2022-07-26 Thread William Wang
+1 (non-binding) bo zhaobo 于2022年7月25日周一 09:38写道： > Hi all, > > Thank you very much for all feedback after the discussion in [2][3]. > Now I'd like to proceed with the vote for FLIP-250 [1], as no more > objections > or issues were raised in ML thread [2][3]. > > The vote will be opened until

Re: [VOTE] FLIP-248: Introduce dynamic partition pruning

2022-07-26 Thread Jing Ge
+1 Thanks for driving this! On Tue, Jul 26, 2022 at 4:01 PM godfrey he wrote: > Hi everyone, > > Thanks for all the feedback so far. Based on the discussion[1] we seem > to have consensus, so I would like to start a vote on FLIP-248 for > which the FLIP has now also been updated[2]. > > The

[jira] [Created] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

2022-07-26 Thread Josh Mahonin (Jira)
Josh Mahonin created FLINK-28697: Summary: MapDataSerializer doesn't declare a serialVersionUID Key: FLINK-28697 URL: https://issues.apache.org/jira/browse/FLINK-28697 Project: Flink Issue

Re: [DISCUSS] FLIP-217 Support watermark alignment of source splits

2022-07-26 Thread Sebastian Mattheis
Hi everybody, I have updated FLIP-217 [1] and have implemented the respective changes in [2]. Please review. If there are no concerns, I would initiate the voting on Thursday. Best regards, Sebastian [1]

[jira] [Created] (FLINK-28696) Notify all newlyAdded/Merged blocked nodes to BlocklistListener

2022-07-26 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-28696: -- Summary: Notify all newlyAdded/Merged blocked nodes to BlocklistListener Key: FLINK-28696 URL: https://issues.apache.org/jira/browse/FLINK-28696 Project: Flink

[jira] [Created] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-07-26 Thread Simonas (Jira)
Simonas created FLINK-28695: --- Summary: Fail to send partition request to restarted taskmanager Key: FLINK-28695 URL: https://issues.apache.org/jira/browse/FLINK-28695 Project: Flink Issue Type:

[VOTE] FLIP-248: Introduce dynamic partition pruning

2022-07-26 Thread godfrey he
Hi everyone, Thanks for all the feedback so far. Based on the discussion[1] we seem to have consensus, so I would like to start a vote on FLIP-248 for which the FLIP has now also been updated[2]. The vote will last for at least 72 hours (Jul 29th 14:00 GMT) unless there is an objection or

[jira] [Created] (FLINK-28694) Set pipeline.name to resource name by default for Applications

2022-07-26 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-28694: -- Summary: Set pipeline.name to resource name by default for Applications Key: FLINK-28694 URL: https://issues.apache.org/jira/browse/FLINK-28694 Project: Flink

[jira] [Created] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression

2022-07-26 Thread Hongbo (Jira)
Hongbo created FLINK-28693: -- Summary: Codegen failed if the watermark is defined on a columnByExpression Key: FLINK-28693 URL: https://issues.apache.org/jira/browse/FLINK-28693 Project: Flink

Re: [DISCUSS] FLIP-248: Introduce dynamic partition pruning

2022-07-26 Thread godfrey he
Thanks for your confirmation. I will start the vote. Best, Godfrey Jing Zhang 于2022年7月26日周二 19:24写道： > > Hi, Godfrey > Thanks for updating the FLIP. > It looks good to me now. > > Best, > Jing Zhang > > godfrey he 于2022年7月26日周二 12:33写道： > > > Thanks for all the inputs, I have updated the

[SUMMARY] Flink 1.16 release sync of 2022-07-26

2022-07-26 Thread Xingbo Huang
Hi everyone, I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-07-26. Currently, we have 17 features that have been completed for this release and 35 features are still expected to make it. We only have 2 weeks remaining until the feature freeze (at

Re: [DISCUSS] FLIP-248: Introduce dynamic partition pruning

2022-07-26 Thread Jing Zhang
Hi, Godfrey Thanks for updating the FLIP. It looks good to me now. Best, Jing Zhang godfrey he 于2022年7月26日周二 12:33写道： > Thanks for all the inputs, I have updated the document and POC code. > > > Best, > Godfrey > > Yun Gao 于2022年7月26日周二 11:11写道： > > > > Hi, > > > > Thanks all for all the

[jira] [Created] (FLINK-28692) Check warehouse path in CatalogFactory

2022-07-26 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28692: Summary: Check warehouse path in CatalogFactory Key: FLINK-28692 URL: https://issues.apache.org/jira/browse/FLINK-28692 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28691) Improve cache hit rate of generated class

2022-07-26 Thread Zou (Jira)
Zou created FLINK-28691: --- Summary: Improve cache hit rate of generated class Key: FLINK-28691 URL: https://issues.apache.org/jira/browse/FLINK-28691 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28690) UpdateSchema#fromCatalogTable lost column comment

2022-07-26 Thread Jane Chan (Jira)
Jane Chan created FLINK-28690: - Summary: UpdateSchema#fromCatalogTable lost column comment Key: FLINK-28690 URL: https://issues.apache.org/jira/browse/FLINK-28690 Project: Flink Issue Type: Bug

Re: [VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal

2022-07-26 Thread Kelu Tao
+1 (non-binding) On 2022/07/25 01:37:56 bo zhaobo wrote: > Hi all, > > Thank you very much for all feedback after the discussion in [2][3]. > Now I'd like to proceed with the vote for FLIP-250 [1], as no more > objections > or issues were raised in ML thread [2][3]. > > The vote will be opened

[jira] [Created] (FLINK-28689) Optimize Spark documentation to Catalog and Dataset

2022-07-26 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28689: Summary: Optimize Spark documentation to Catalog and Dataset Key: FLINK-28689 URL: https://issues.apache.org/jira/browse/FLINK-28689 Project: Flink Issue

Re: [DISCUSS] FLIP-248: Introduce dynamic partition pruning

2022-07-26 Thread Jingsong Li
Thanks for the update. Looks good to me. Best, Jingsong On Tue, Jul 26, 2022 at 3:21 PM Jark Wu wrote: > > Thank you Godfrey, the FLIP looks good to me. > > Best, > Jark > > On Tue, 26 Jul 2022 at 12:34, godfrey he wrote: > > > Thanks for all the inputs, I have updated the document and POC

Re: [VOTE] FLIP-247 Bulk fetch of table and column statistics for given partitions

2022-07-26 Thread Jingsong Li
+1 Best, Jingsong On Tue, Jul 26, 2022 at 10:11 AM godfrey he wrote: > > +1 > > Best, > Godfrey > > Jark Wu 于2022年7月25日周一 17:23写道： > > > > +1 (binding) > > > > Best, > > Jark > > > > On Mon, 25 Jul 2022 at 15:10, Jing Ge wrote: > > > > > Hi all, > > > > > > Many thanks for all your feedback.

[jira] [Created] (FLINK-28688) Support DataStream PythonWindowOperator in Thread Mode

2022-07-26 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28688: Summary: Support DataStream PythonWindowOperator in Thread Mode Key: FLINK-28688 URL: https://issues.apache.org/jira/browse/FLINK-28688 Project: Flink Issue

[jira] [Created] (FLINK-28687) BucketSelector is wrong when hashcode is negative

2022-07-26 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28687: Summary: BucketSelector is wrong when hashcode is negative Key: FLINK-28687 URL: https://issues.apache.org/jira/browse/FLINK-28687 Project: Flink Issue

[jira] [Created] (FLINK-28686) Spark table with column comment cannot be read/write by Flink

2022-07-26 Thread Jane Chan (Jira)
Jane Chan created FLINK-28686: - Summary: Spark table with column comment cannot be read/write by Flink Key: FLINK-28686 URL: https://issues.apache.org/jira/browse/FLINK-28686 Project: Flink

Re: [DISCUSS] FLIP-248: Introduce dynamic partition pruning

2022-07-26 Thread Jark Wu
Thank you Godfrey, the FLIP looks good to me. Best, Jark On Tue, 26 Jul 2022 at 12:34, godfrey he wrote: > Thanks for all the inputs, I have updated the document and POC code. > > > Best, > Godfrey > > Yun Gao 于2022年7月26日周二 11:11写道： > > > > Hi, > > > > Thanks all for all the valuable