[jira] [Created] (FLINK-27889) Error when the LastReconciledSpec is null

2022-06-02 Thread Hector Miuler Malpica Gallegos (Jira)
Hector Miuler Malpica Gallegos created FLINK-27889: -- Summary: Error when the LastReconciledSpec is null Key: FLINK-27889 URL: https://issues.apache.org/jira/browse/FLINK-27889

Needed help with skipping savepoint state (unsure how to set --allowNonRestoredState in Docker)

2022-06-02 Thread Bhavani Balasubramanyam
Hi, I am Bhavani, a Software Engineer at Reddit. I'm trying to upgrade the Flink version in my application from 3.0.0 to version 3.2.0, and in the process I see the below error, where the the operator has been removed, and the checkpoint is unable to recover: - Jun 2 14:32:03

[jira] [Created] (FLINK-27888) Flink SQL execute error in Flink1.15

2022-06-02 Thread songwenbin (Jira)
songwenbin created FLINK-27888: -- Summary: Flink SQL execute error in Flink1.15 Key: FLINK-27888 URL: https://issues.apache.org/jira/browse/FLINK-27888 Project: Flink Issue Type: Bug

Re: Join Apache Flink community on Slack

2022-06-02 Thread xun wang
Hi I have joined Slack, thank you for your invitation! Martijn Visser 于2022年6月2日周四 23:34写道: > Hi, > > I've just invited you manually. When checking the invite link at > https://flink.apache.org/community.html#slack it is still working. But > thanks for reaching out! > > Best regards, Martijn >

[jira] [Created] (FLINK-27887) Unable to access https://nightlies.apache.org/flink/

2022-06-02 Thread Ben Carlton (Jira)
Ben Carlton created FLINK-27887: --- Summary: Unable to access https://nightlies.apache.org/flink/ Key: FLINK-27887 URL: https://issues.apache.org/jira/browse/FLINK-27887 Project: Flink Issue

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

2022-06-02 Thread Jing Ge
Thanks everyone for your effort! Best regards, Jing On Thu, Jun 2, 2022 at 4:17 PM Martijn Visser wrote: > Thanks everyone for joining! It's good to see so many have joined in such > a short time already. I've just refreshed the link which you can always > find on the project website [1] > >

Re: [DISCUSS] suggest using granularityNumber in ColumnStats

2022-06-02 Thread Jing Ge
Thanks all for your feedback! It is very informative. to Becket: At the beginning, I chose the same word because we used it in daily work. Before I started this discussion, to make sure it is the right one, I did some checking and it turns out that *cardinality* has a very different (also very

Re: Re:RE: RE: [DISCUSS] FLIP-233: Introduce HTTP Connector

2022-06-02 Thread Martijn Visser
Hi all, Thanks for opening a discussion and/or creating a FLIP. I do think that a HTTP connector could be a powerful connector for users. In order to get a proper HTTP connector in as part of the Apache Flink project, we'll need to have FLIP and a successful vote. When that's done, one of the

Re: Join Apache Flink community on Slack

2022-06-02 Thread Martijn Visser
Hi, I've just invited you manually. When checking the invite link at https://flink.apache.org/community.html#slack it is still working. But thanks for reaching out! Best regards, Martijn Op do 2 jun. 2022 om 17:06 schreef xun wang : > Hello,I want join Apache Flink community on Slack,and when

[jira] [Created] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread Ran Tao (Jira)
Ran Tao created FLINK-27886: --- Summary: Error way for skipping shade plugin in sub-modules Key: FLINK-27886 URL: https://issues.apache.org/jira/browse/FLINK-27886 Project: Flink Issue Type:

Join Apache Flink community on Slack

2022-06-02 Thread xun wang
Hello,I want join 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?

[jira] [Created] (FLINK-27885) [JUnit5 Migration] Module: flink-csv

2022-06-02 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-27885: --- Summary: [JUnit5 Migration] Module: flink-csv Key: FLINK-27885 URL: https://issues.apache.org/jira/browse/FLINK-27885 Project: Flink Issue Type: Sub-task

Re: Re:RE: RE: [DISCUSS] FLIP-233: Introduce HTTP Connector

2022-06-02 Thread Ber, Jeremy
Hi Xuyang, Great feedback on the early days of this FLIP! With respect to the Source question, definitely want to add a source connector in collaboration with the getindata folks below in this thread. We will collaborate to make HTTP source changes. I agree that FLIP-171 is the cornerstone

邮件退订

2022-06-02 Thread 王飞
邮件退订

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

2022-06-02 Thread Martijn Visser
Thanks everyone for joining! It's good to see so many have joined in such a short time already. I've just refreshed the link which you can always find on the project website [1] Best regards, Martijn [1] https://flink.apache.org/community.html#slack Op do 2 jun. 2022 om 11:42 schreef Jingsong

邮件退订

2022-06-02 Thread 米子日匀
邮件退订

[jira] [Created] (FLINK-27884) Introduce a flush mechanism for OutputFormats

2022-06-02 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-27884: Summary: Introduce a flush mechanism for OutputFormats Key: FLINK-27884 URL: https://issues.apache.org/jira/browse/FLINK-27884 Project: Flink Issue

[jira] [Created] (FLINK-27883) KafkaSubscriberTest failed with NPC

2022-06-02 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-27883: Summary: KafkaSubscriberTest failed with NPC Key: FLINK-27883 URL: https://issues.apache.org/jira/browse/FLINK-27883 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27882) [JUnit5 Migration] Module: flink-scala

2022-06-02 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-27882: --- Summary: [JUnit5 Migration] Module: flink-scala Key: FLINK-27882 URL: https://issues.apache.org/jira/browse/FLINK-27882 Project: Flink Issue Type:

Re: Translation in korean?

2022-06-02 Thread Dennis Jung
Thanks for sharing. Seems it is difficult to work on a community level. I'll try to make it by myself first. 2022년 6월 1일 (수) 오후 10:15, Daisy Tsang 님이 작성: > Not sure whether this helps, but there was a previous discussion regarding > adding support for the Japanese language: >

Re: [DISCUSS] Bi-Weekly Flink Community Sync Meeting

2022-06-02 Thread Robert Metzger
Thanks for your feedback! Nobody should feel obliged to attend these meetings, or fear that they are missing something by not attending. Everything relevant discussed there has to be reflected on the mailing list, either as a meeting summary, or in existing discussion threads. My main motivation

[jira] [Created] (FLINK-27881) The key(String) in PulsarMessageBuilder returns null

2022-06-02 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-27881: -- Summary: The key(String) in PulsarMessageBuilder returns null Key: FLINK-27881 URL: https://issues.apache.org/jira/browse/FLINK-27881 Project: Flink

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

2022-06-02 Thread Jingsong Li
Thanks Xingtong, Jark, Martijn and Robert for making this possible! Best, Jingsong On Thu, Jun 2, 2022 at 5:32 PM Jark Wu wrote: > Thank Xingtong for making this possible! > > Cheers, > Jark Wu > > On Thu, 2 Jun 2022 at 15:31, Xintong Song wrote: > > > Hi everyone, > > > > I'm very happy to

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

2022-06-02 Thread Jark Wu
Thank Xingtong for making this possible! Cheers, Jark Wu On Thu, 2 Jun 2022 at 15:31, Xintong Song wrote: > Hi everyone, > > I'm very happy to announce that the Apache Flink community has created a > dedicated Slack workspace [1]. Welcome to join us on Slack. > > ## Join the Slack workspace >

Re: [DISCUSS] suggest using granularityNumber in ColumnStats

2022-06-02 Thread Jingsong Li
Hi, +1 for NDV (number of distinct values) is a widely used terminology in table statistics. I've also seen the one called `distinctCount`. This name can be found in databases like oracle too. [1] So it is not good to change a completely different name. [1]

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

2022-06-02 Thread Qingsheng Ren
Hi Becket, Thanks for your feedback! 1. An alternative way is to let the implementation of cache to decide whether to store a missing key in the cache instead of the framework. This sounds more reasonable and makes the LookupProvider interface cleaner. I can update the FLIP and clarify in the

回复: [DISCUSS] suggest using granularityNumber in ColumnStats

2022-06-02 Thread luoyu...@alumni.sjtu.edu.cn
As I'm work with getting statistic for Hive's partitioned table[1] currently, I would like to shard my expirence 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".

[jira] [Created] (FLINK-27880) CI runs keep getting stuck

2022-06-02 Thread Alexander Preuss (Jira)
Alexander Preuss created FLINK-27880: Summary: CI runs keep getting stuck Key: FLINK-27880 URL: https://issues.apache.org/jira/browse/FLINK-27880 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27879) Translate the "Documentation Style Guide" page into Chinese

2022-06-02 Thread zhenyu xing (Jira)
zhenyu xing created FLINK-27879: --- Summary: Translate the "Documentation Style Guide" page into Chinese Key: FLINK-27879 URL: https://issues.apache.org/jira/browse/FLINK-27879 Project: Flink

Re: [DISCUSS] suggest using granularityNumber in ColumnStats

2022-06-02 Thread Jark Wu
Hi Jing, I can see there might be developers who don't understand the meaning at the first glance. However, NDV is a widely used terminology in table statistics, see [1][2][3]. If we use another name, it may confuse developers who are familiar with stats and optimization. I think at least, the

[jira] [Created] (FLINK-27878) Add Retry Support For Async I/O In DataStream API

2022-06-02 Thread lincoln lee (Jira)
lincoln lee created FLINK-27878: --- Summary: Add Retry Support For Async I/O In DataStream API Key: FLINK-27878 URL: https://issues.apache.org/jira/browse/FLINK-27878 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems

2022-06-02 Thread Lincoln Lee
Hi everyone, When reviewing the name of the hint option 'miss-retry'='true|false', I feel the current name is not precise enough, it might be easier to understand by using the retry-predicate directly from flip-232, e.g. 'retry-predicate'='lookup-miss', which has the additional benefit of

[RESULT] [VOTE] FLIP-232: Add Retry Support For Async I/O In DataStream API

2022-06-02 Thread Lincoln Lee
Hi everyone, FLIP-232[1] has been accepted. There are 4 approving votes, 3 of which are binding[2] - Binding: Jark Wu - Non-Binding: Gen Luo - Binding: Jingsong Li - Binding: Yun Gao None against. Thanks again to everyone! [1]

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

2022-06-02 Thread Xintong Song
Hi everyone, I'm very happy to announce that the Apache Flink community has created a dedicated Slack workspace [1]. Welcome to join us on Slack. ## Join the Slack workspace You can join the Slack workspace by either of the following two ways: 1. Click the invitation link posted on the project

邮件退订

2022-06-02 Thread lizikun
邮件退订

Re: [DISCUSS] suggest using granularityNumber in ColumnStats

2022-06-02 Thread Becket Qin
Hi Jing, While I do agree that NDV is a little confusing at first sight, it seems quite concise once I got the meaning. So personally I am OK with keeping it as is, but proper documentation would be helpful. If we really want to replace it with a more professional name, *cardinality* might be a

[jira] [Created] (FLINK-27877) Improve performance of several feature engineering algorithms

2022-06-02 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-27877: - Summary: Improve performance of several feature engineering algorithms Key: FLINK-27877 URL: https://issues.apache.org/jira/browse/FLINK-27877 Project: Flink