??????RE: [DISCUSS] Release Kubernetes operator 1.0.1

+1 for the this release. Thanks Gyula! Best, Jun He --  -- ??: "dev"

Re:RE: [DISCUSS] Release Kubernetes operator 1.0.1

+1 for this. Thanks Gyula ! Best, Lihe Ma At 2022-06-23 21:19:34, "zhengyu chen" wrote: >+1 >for the patch release. > >-- >Best > >ConradJam

Re: [VOTE] FLIP-221: Abstraction for lookup source and metric

+1 (non-binding) Best, Lincoln Lee Alexander Smirnov 于2022年6月24日周五 09:54写道： > +1 (non-binding) > > Best, > Alexander > > чт, 23 июн. 2022 г., 11:49 Qingsheng Ren : > > > Hi devs, > > > > I’d like to start a vote thread for FLIP-221: Abstraction for lookup > > source and metric. You can find t

Re: [DISCUSS] FLIP-241: Completed Jobs Information Enhancement

Whether the job ID is actually used in the end isn't visible after all. I'm not sure about this. E.g., for an empty session cluster, users have to understand they don't need to provide an actual jobid for requesting jobmanager information via rest. I believe both ways work. I think this is a trad

[jira] [Created] (FLINK-28238) Fix unstable testCancelOperationAndFetchResultInParallel

Shengkai Fang created FLINK-28238: - Summary: Fix unstable testCancelOperationAndFetchResultInParallel Key: FLINK-28238 URL: https://issues.apache.org/jira/browse/FLINK-28238 Project: Flink Is

[jira] [Created] (FLINK-28237) Improve the flink-ml python examples in doc

Huang Xingbo created FLINK-28237: Summary: Improve the flink-ml python examples in doc Key: FLINK-28237 URL: https://issues.apache.org/jira/browse/FLINK-28237 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-28236) managed memory  no  matter how much I configure, it will be exhausted

LCER created FLINK-28236: Summary: managed memory  no  matter how much I configure, it will be exhausted Key: FLINK-28236 URL: https://issues.apache.org/jira/browse/FLINK-28236 Project: Flink Issue

Re: [DISCUSS] Releasing Flink ML 2.1.0

+1. It looks like we have some decent progress on Flink ML :) Thanks, Jiangjie (Becket) Qin On Fri, Jun 24, 2022 at 8:29 AM Dong Lin wrote: > Hi Zhipeng and Yun, > > Thanks for starting the discussion. +1 for the Flink ML 2.1.0 release. > > Cheers, > Dong > > On Thu, Jun 23, 2022 at 11:15 AM

[jira] [Created] (FLINK-28235) Min aggregate function support type: ''ARRAY''.

tartarus created FLINK-28235: Summary: Min aggregate function support type: ''ARRAY''. Key: FLINK-28235 URL: https://issues.apache.org/jira/browse/FLINK-28235 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28234) Infinite or NaN exception for power(-1, 0.5)

luoyuxia created FLINK-28234: Summary: Infinite or NaN exception for power(-1, 0.5) Key: FLINK-28234 URL: https://issues.apache.org/jira/browse/FLINK-28234 Project: Flink Issue Type: Improvement

Re: [VOTE] FLIP-221: Abstraction for lookup source and metric

+1 (non-binding) Best, Alexander чт, 23 июн. 2022 г., 11:49 Qingsheng Ren : > Hi devs, > > I’d like to start a vote thread for FLIP-221: Abstraction for lookup > source and metric. You can find the discussion thread in [2]*. > > The vote will be open for at least 72 hours unless there is an obje

Re: Re: [VOTE] FLIP-221: Abstraction for lookup source and metric

+1 Best, Jingsong On Fri, Jun 24, 2022 at 9:30 AM zst...@163.com wrote: > > Thanks Qingsheng for driving this. > > > > > +1 (non-binding) > > > > > Best regards, > > Yuan > > > > > At 2022-06-23 15:44:55, "Martijn Visser" wrote: > >Great work on the FLIP. > > > >+1 (binding) > > > >Op do 23 jun

[DISCUSS] Contribution of Multi Cluster Kafka Source

Hi community, We have been working on a Multi Cluster Kafka Source and are looking to contribute it upstream. I've given a talk about the features and design at a Flink meetup: https://youtu.be/H1SYOuLcUTI. The main features that it provides is: 1. Reading multiple Kafka clusters within a single

Re:Re: [VOTE] FLIP-221: Abstraction for lookup source and metric

Thanks Qingsheng for driving this. +1 (non-binding) Best regards, Yuan At 2022-06-23 15:44:55, "Martijn Visser" wrote: >Great work on the FLIP. > >+1 (binding) > >Op do 23 jun. 2022 om 08:07 schreef Leonard Xu : > >> Thanks Qingsheng for driving this work. >> >> +1(binding) >> >> >> B

Re: [DISCUSS] Releasing Flink ML 2.1.0

Hi Zhipeng and Yun, Thanks for starting the discussion. +1 for the Flink ML 2.1.0 release. Cheers, Dong On Thu, Jun 23, 2022 at 11:15 AM Zhipeng Zhang wrote: > Hi devs, > > Yun and I would like to start a discussion for releasing Flink ML > 2.1.0. > > In th

[jira] [Created] (FLINK-28233) Successful observe doesn't clear errors due to patching

Gyula Fora created FLINK-28233: -- Summary: Successful observe doesn't clear errors due to patching Key: FLINK-28233 URL: https://issues.apache.org/jira/browse/FLINK-28233 Project: Flink Issue Typ

[jira] [Created] (FLINK-28232) Allow for custom pre-flight checks for SQL UDFs

Robert Metzger created FLINK-28232: -- Summary: Allow for custom pre-flight checks for SQL UDFs Key: FLINK-28232 URL: https://issues.apache.org/jira/browse/FLINK-28232 Project: Flink Issue Typ

[jira] [Created] (FLINK-28231) Support Ozone file system

bianqi created FLINK-28231: -- Summary: Support Ozone file system Key: FLINK-28231 URL: https://issues.apache.org/jira/browse/FLINK-28231 Project: Flink Issue Type: New Feature Components: f

Re: Re: [DISCUSS] FLIP-240: Introduce "ANALYZE TABLE" Syntax

Hi, everyone. Thanks for all the inputs. If there is no feedback any more, I will start the vote tomorrow. Best, Godfrey Jing Ge 于2022年6月22日周三 15:50写道： > > sounds good to me. Thanks! > > Best regards, > Jing > > On Fri, Jun 17, 2022 at 5:37 AM godfrey he wrote: > > > Hi, Jing. > > > > Thanks f

Re: [DISCUSS] FLIP-223: Implement standalone mode support in the kubernetes operator

I think Usamah is working right now towards a first prototype PR of the standalone implementation. We should wait for that before we start splitting the work :) Gyula On Thu, Jun 23, 2022 at 3:25 PM zhengyu chen wrote: > I only see LAST_STATE support for zookeeper here（FLINK-27416 >

RE: [DISCUSS] FLIP-223: Implement standalone mode support in the kubernetes operator

I only see LAST_STATE support for zookeeper here（FLINK-27416 ）, but I don't see anything about k8s. What do you think about this? I am very willing to move this work forward -- Best ConradJam

RE: [DISCUSS] Release Kubernetes operator 1.0.1

+1 for the patch release. -- Best ConradJam

[jira] [Created] (FLINK-28230) Deduplicate Dependency classes across checks

Chesnay Schepler created FLINK-28230: Summary: Deduplicate Dependency classes across checks Key: FLINK-28230 URL: https://issues.apache.org/jira/browse/FLINK-28230 Project: Flink Issue Ty

[jira] [Created] (FLINK-28229) Introduce Source API alternatives for StreamExecutionEnvironment#fromCollection() methods

Alexander Fedulov created FLINK-28229: - Summary: Introduce Source API alternatives for StreamExecutionEnvironment#fromCollection() methods Key: FLINK-28229 URL: https://issues.apache.org/jira/browse/FLINK-2822

Re: [DISCUSS] Releasing Flink ML 2.1.0

Hi Yun and Zhipeng, Thanks a lot for starting the discussion. +1 for the FLINK ML 2.1.0 release. Looking forward for these ML algorithms. I plan to write a blog about PyFlink + Flink ML after the released. Best, Xingbo Zhipeng Zhang 于2022年6月23日周四 11:15写道： > Hi devs, > > Yun and I would like to

[jira] [Created] (FLINK-28228) Target generation logic might skip over specs when observing already upgraded clusters

Gyula Fora created FLINK-28228: -- Summary: Target generation logic might skip over specs when observing already upgraded clusters Key: FLINK-28228 URL: https://issues.apache.org/jira/browse/FLINK-28228 Pr

[jira] [Created] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

Alexander Fedulov created FLINK-28227: - Summary: Add implementations for classes in o.a.f.streaming.examples based on the new new Source API Key: FLINK-28227 URL: https://issues.apache.org/jira/browse/FLINK-28

[jira] [Created] (FLINK-28226) 'Run kubernetes pyflink application test' fail with "[FAIL] Test script contains errors"

Martijn Visser created FLINK-28226: -- Summary: 'Run kubernetes pyflink application test' fail with "[FAIL] Test script contains errors" Key: FLINK-28226 URL: https://issues.apache.org/jira/browse/FLINK-28226

Re: [DISCUSS] Maintain a Calcite repository for Flink to accelerate the development for Flink SQL features

Hi Jing, My pleasure. I also saw some reviews coming in from Julian on your Calcite PR, so that's great :) > About keeping up with the Calcite updates, I would like to take this issue. Is it too late to schedule the 1.16 version? How about scheduling this work on version 1.17? I'm not sure if th

[jira] [Created] (FLINK-28225) Supports custom ENVs in the Helm chart

Xin Hao created FLINK-28225: --- Summary: Supports custom ENVs in the Helm chart Key: FLINK-28225 URL: https://issues.apache.org/jira/browse/FLINK-28225 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28224) Add document for algorithms and features in Flink ML 2.1

Yunfeng Zhou created FLINK-28224: Summary: Add document for algorithms and features in Flink ML 2.1 Key: FLINK-28224 URL: https://issues.apache.org/jira/browse/FLINK-28224 Project: Flink Issu

[jira] [Created] (FLINK-28223) Add artifact-fetcher to the pod-template.yaml example

Matyas Orhidi created FLINK-28223: - Summary: Add artifact-fetcher to the pod-template.yaml example Key: FLINK-28223 URL: https://issues.apache.org/jira/browse/FLINK-28223 Project: Flink Issue

[jira] [Created] (FLINK-28222) Add sql-csv/json modules

Chesnay Schepler created FLINK-28222: Summary: Add sql-csv/json modules Key: FLINK-28222 URL: https://issues.apache.org/jira/browse/FLINK-28222 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-28221) Savepoint may corrupt file metas by repeat commit

Jingsong Lee created FLINK-28221: Summary: Savepoint may corrupt file metas by repeat commit Key: FLINK-28221 URL: https://issues.apache.org/jira/browse/FLINK-28221 Project: Flink Issue Type:

Re: [DISCUSS] Release Kubernetes operator 1.0.1

Thanks Gyula for preparing the first patch release for Flink Kubernetes operator. +1 for this. Best, Yang Őrhidi Mátyás 于2022年6月22日周三 23:38写道： > +1 for the patch release. Thanks Gyula! > > On Wed, Jun 22, 2022 at 5:35 PM Márton Balassi > wrote: > >> Hi team, >> >> +1 for having a 1.0.1 for th

[jira] [Created] (FLINK-28220) Create Table Like support excluding physical columns

JustinLee created FLINK-28220: - Summary: Create Table Like support excluding physical columns Key: FLINK-28220 URL: https://issues.apache.org/jira/browse/FLINK-28220 Project: Flink Issue Type: Im

Re: [DISCUSS] FLIP-241: Completed Jobs Information Enhancement

The addition of the /jobs/:jobid/jobmanager/config / environment exclusively to the HS is a bit of a strange workaround. How do you intend to document those? (and test compatibility)? Why not just add a general /jobs/:jobid/environment endpoint that works just like jobmanager/environment. To m

Re: [DISCUSS] FLIP-242: Introduce configurable CongestionControlStrategy for Async Sink

Hi Hong, As I understand it, this effort is about replacing hardcoded `AIMDRateLimitingStrategy` with something more flexible? +1 for the general idea. If I read it correctly, there are basically three issues: 1. (what) `AIMDRateLimitingStrategy` is only able to limit the size of all in-flight re

Re: [VOTE] FLIP-241: Completed Jobs Information Enhancement

+1 (binding) Best, Xintong On Thu, Jun 23, 2022 at 1:49 PM Yangze Guo wrote: > +1 (binding) > > Best, > Yangze Guo > > On Thu, Jun 23, 2022 at 1:07 PM junhan yang > wrote: > > > > Hi everyone, > > > > Thanks for the feedbacks on the discussion thread[1]. I would like to > start > > a vote t

Re: [VOTE] FLIP-221: Abstraction for lookup source and metric

Great work on the FLIP. +1 (binding) Op do 23 jun. 2022 om 08:07 schreef Leonard Xu : > Thanks Qingsheng for driving this work. > > +1(binding) > > > Best, > Leonard > > 2022年6月23日 下午1:37，Jark Wu 写道： > > > > +1 (binding) > > > > Best, > > Jark > > > > On Thu, 23 Jun 2022 at 12:49, Qingsheng Ren

[jira] [Created] (FLINK-28219) Refactor TableStoreCatalog: Introduce a dedicated Catalog for table store

Jingsong Lee created FLINK-28219: Summary: Refactor TableStoreCatalog: Introduce a dedicated Catalog for table store Key: FLINK-28219 URL: https://issues.apache.org/jira/browse/FLINK-28219 Project: Fl

[jira] [Created] (FLINK-28218) Add readiness and liveliness probe to k8s operator

Márton Balassi created FLINK-28218: -- Summary: Add readiness and liveliness probe to k8s operator Key: FLINK-28218 URL: https://issues.apache.org/jira/browse/FLINK-28218 Project: Flink Issue

[jira] [Created] (FLINK-28217) Bump mysql-connector-java from 8.0.27 to 8.0.28

Martijn Visser created FLINK-28217: -- Summary: Bump mysql-connector-java from 8.0.27 to 8.0.28 Key: FLINK-28217 URL: https://issues.apache.org/jira/browse/FLINK-28217 Project: Flink Issue Typ

[jira] [Created] (FLINK-28216) Hadoop S3FileSystemFactory does not honor fs.s3.impl

Prabhu Joseph created FLINK-28216: - Summary: Hadoop S3FileSystemFactory does not honor fs.s3.impl Key: FLINK-28216 URL: https://issues.apache.org/jira/browse/FLINK-28216 Project: Flink Issue