Re: [DISCUSS] Deprecate SourceFunction APIs

2022-06-04 Thread Jingsong Lee
+1 to David and Ingo. Before deprecate and remove SourceFunction, we should have some easier APIs to wrap new Source, the cost to write a new Source is too high now. Ingo Bürk 于2022年6月5日 周日05:32写道: > I +1 everything David said. The new Source API raised the complexity > significantly. It's

Re: [DISCUSS] Deprecate SourceFunction APIs

2022-06-04 Thread Ingo Bürk
I +1 everything David said. The new Source API raised the complexity significantly. It's great to have such a rich, powerful API that can do everything, but in the process we lost the ability to onboard people to the APIs. Best Ingo On 04.06.22 21:21, David Anderson wrote: I'm in favor of

Re: [DISCUSS] Deprecate SourceFunction APIs

2022-06-04 Thread David Anderson
I'm in favor of this, but I think we need to make it easier to implement data generators and test sources. As things stand in 1.15, unless you can be satisfied with using a NumberSequenceSource followed by a map, things get quite complicated. I looked into reworking the data generators used in the

Re: Need help to join Apache Flink community on.Slack

2022-06-04 Thread Jing Ge
glad to help! Looking forward to chatting with you. On Sat, Jun 4, 2022 at 8:23 PM Sriram Ganesh wrote: > Thanks a lot Jing with your help I joined the Slack channel. > > On Sat, Jun 4, 2022, 23:26 Jing Ge wrote: > > > Hi, > > > > I have just invited you. Please check your email. Thanks. > > >

Re: Need help to join Apache Flink community on.Slack

2022-06-04 Thread Sriram Ganesh
Thanks a lot Jing with your help I joined the Slack channel. On Sat, Jun 4, 2022, 23:26 Jing Ge wrote: > Hi, > > I have just invited you. Please check your email. Thanks. > > Best regards, > Jing > > On Sat, Jun 4, 2022 at 7:49 PM Jing Ge wrote: > > > Hi, > > > > Do you want to use

Re: [ANNOUNCE] Welcome to join the Apache Flink community on Slack

2022-06-04 Thread Jing Ge
Hi Xingtong, While inviting new members, there are two options: "From another company" vs "Your coworker". In this case, we should always choose "Your coworker" to add new members to the Apache Flink workspace, right? Best regards, Jing On Fri, Jun 3, 2022 at 1:10 PM Yuan Mei wrote: > Thanks,

Re: Need help to join Apache Flink community on.Slack

2022-06-04 Thread Jing Ge
Hi, I have just invited you. Please check your email. Thanks. Best regards, Jing On Sat, Jun 4, 2022 at 7:49 PM Jing Ge wrote: > Hi, > > Do you want to use srigns...@gmail.com to join slack? Someone who has > already joined can invite you[1]. > > [1]

Re: Need help to join Apache Flink community on.Slack

2022-06-04 Thread Jing Ge
Hi, Do you want to use srigns...@gmail.com to join slack? Someone who has already joined can invite you[1]. [1] https://lists.apache.org/list?dev@flink.apache.org:lte=1M:slack On Sat, Jun 4, 2022 at 5:41 PM Sriram Ganesh wrote: > Hi Everyone, > > I want to join the Apache Flink community on

Need help to join Apache Flink community on.Slack

2022-06-04 Thread Sriram Ganesh
Hi Everyone, I want to join the Apache Flink community on Slack, and when I click the link, it displays "*This link is no longer effective"*, Could you invite me to go in? Thanks, -- *Sriram G* *Tech*

[jira] [Created] (FLINK-27897) SearchArgumentToPredicateConverter can not handle partial filters

2022-06-04 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27897: Summary: SearchArgumentToPredicateConverter can not handle partial filters Key: FLINK-27897 URL: https://issues.apache.org/jira/browse/FLINK-27897 Project: Flink

Re: [DISCUSS] suggest using granularityNumber in ColumnStats

2022-06-04 Thread Yuxia Luo
Recently, I'm work with getting statistic for Hive's partitioned table[1], I would like to share my experience as a developer. I have to admit the ndv really make me confused in the first glance, but I can find what it means easily in web search engine with the keyword like "nvd statistic".

Re: [DISCUSS] suggest using granularityNumber in ColumnStats

2022-06-04 Thread Becket Qin
Hi Jing, Hmm, granularity and ndv still don't seem to mean the same thing to me. Granularity basically means how detailed the data is, in another word, whether a field / column be further divided. For example, a field like "age“ cannot be further divided so it is quite granular. In contrast, an

[jira] [Created] (FLINK-27896) Clean up FlinkService#cancelJob implementation

2022-06-04 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-27896: -- Summary: Clean up FlinkService#cancelJob implementation Key: FLINK-27896 URL: https://issues.apache.org/jira/browse/FLINK-27896 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-222: Support full query lifecycle statements in SQL client

2022-06-04 Thread Paul Lam
Hi Godfrey, Sorry for the late reply, I was on vacation. It looks like we have a variety of preferences on the syntax, how about we choose the most acceptable one? WRT keyword for SQL jobs, we use JOBS, thus the statements related to jobs would be: - SHOW JOBS - STOP JOBS (with options