Re: About Deprecating split/select for DataStream API

+1 to keep the split/select API. I think if there are some problems with the API, it's better to fix them instead of deprecating them. And select/split are straightforward and convenient APIs. It's worth to have them. Regards, Jark On Mon, 17 Jun 2019 at 14:46, vino yang wrote: > Hi, > > I also

Re: About Deprecating split/select for DataStream API

Hi, I also think it is valuable and reasonable to keep the split/select APIs. They are very convenient and widely used in our platform. I think they are also used in other users' jobs. If the community has doubts about this, IMHO, it would be better to start a user survey. Best, Vino SHI Xiaogan

[jira] [Created] (FLINK-12867) Add insert overwrite grammar as HIVE dialect

Danny Chan created FLINK-12867: -- Summary: Add insert overwrite grammar as HIVE dialect Key: FLINK-12867 URL: https://issues.apache.org/jira/browse/FLINK-12867 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12866) Connectors module failed on Travis checking

Biao Liu created FLINK-12866: Summary: Connectors module failed on Travis checking Key: FLINK-12866 URL: https://issues.apache.org/jira/browse/FLINK-12866 Project: Flink Issue Type: Test

Re: About Deprecating split/select for DataStream API

Hi Xingcan, Thanks for bringing it up for discusson. I agree with you that we should not deprecate the split/select methods. Their semantics are very clear and they are widely adopted by Flink users. We should fix these problems instead of simply deprecating the methods. Regards, Xiaogang Xingc

[jira] [Created] (FLINK-12865) State inconsistency between RM and TM on the slot status

Yun Gao created FLINK-12865: --- Summary: State inconsistency between RM and TM on the slot status Key: FLINK-12865 URL: https://issues.apache.org/jira/browse/FLINK-12865 Project: Flink Issue Type: Bu

Re: [DISCUSS] Start a user...@flink.apache.org mailing list for the Chinese-speaking community?

>> We did guide users to use mailing list to ask questions, but people still prefer DingTalk. We can continue to remind users to use mailing list frequently. > Do we know why that's the case? Do we need to educate people more on mailing lists? - Because it's easy and fast as Bowen and Hequn said.

[VOTE] FLIP-41: Unified binary format for keyed state

Hi Flink devs, I want to officially start a voting thread to formally adopt FLIP-41 [1]. There are two relevant discussions threads for this feature [2] [3]. The voting time will end on June 19th 17:00 CET. Cheers, Gordon [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-41:+Unify+Key

Re: [DISCUSS] FLIP-41: Unify Keyed State Snapshot Binary Format for Savepoints

Thanks for the inputs Yu and Aljoscha! I agree to rename this FLIP. Will call it "Unified binary format for Keyed State". I will proceed to open a VOTE thread to formally adopt the FLIP now. On Fri, Jun 14, 2019 at 10:03 PM Aljoscha Krettek wrote: > Please also see my comment on > https://issu

Re: [DISCUSS] Proposal for Flink job execution/availability metrics impovement

Hi Hwanju, Thanks for the proposal. The enhancement will improve the operability of Flink and make it more service provider friendly. So in general I am +1 on the proposal. A few questions / thoughts: 1. From what I understand, the current availability metrics

Re: [DISCUSS] Releasing Flink 1.8.1

Hi Till, Thank you for this timely discovery! @Till Rohrmann We would start the release process after FLINK-12863 resolved! Best, Jincheng Till Rohrmann 于2019年6月16日周日 下午10:03写道： > Hi Jincheng, > > I just realized that we introduced a race co

Apply for contributor permission

Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is yuetongshu Regards, Jasper Yue

Re: [ANNOUNCE] Weekly Community Update 2019/24

Hi Konstantin and all, Thank Konstantin very much for reviving this tradition! It reminds me of the joyful time I can easily catch up interesting ongoing threads. Thanks for Till's work, too. Besides exciting updates and news above, I'd like to pick up some other threads you guys may be intereste

[ANNOUNCE] Weekly Community Update 2019/24

Dear community, last year Till did a great job on summarizing recent developments in the Flink community in a "Weekly community update" thread. I found this very helpful and would like to revive this tradition with a focus on topics & threads which are particularly relevant to the wider community

[jira] [Created] (FLINK-12864) Improves the performance of Python Table API test cases

Dian Fu created FLINK-12864: --- Summary: Improves the performance of Python Table API test cases Key: FLINK-12864 URL: https://issues.apache.org/jira/browse/FLINK-12864 Project: Flink Issue Type: Sub

Re: [DISCUSS] Releasing Flink 1.8.1

Hi Jincheng, I just realized that we introduced a race condition with FLINK-11059. We first need to fix this problem [1] before we can start the release process. [1] https://issues.apache.org/jira/browse/FLINK-12863 Cheers, Till On Sat, Jun 15, 2019 at 3:48 PM jincheng sun wrote: > I am very

[jira] [Created] (FLINK-12863) Race condition between slot offerings and AllocatedSlotReport

Till Rohrmann created FLINK-12863: - Summary: Race condition between slot offerings and AllocatedSlotReport Key: FLINK-12863 URL: https://issues.apache.org/jira/browse/FLINK-12863 Project: Flink

[jira] [Created] (FLINK-12862) Remove legacy class QuarantineHandler and QuarantineMonitor

TisonKun created FLINK-12862: Summary: Remove legacy class QuarantineHandler and QuarantineMonitor Key: FLINK-12862 URL: https://issues.apache.org/jira/browse/FLINK-12862 Project: Flink Issue Ty

[jira] [Created] (FLINK-12861) Remove legacy class ListeningBehaviour

TisonKun created FLINK-12861: Summary: Remove legacy class ListeningBehaviour Key: FLINK-12861 URL: https://issues.apache.org/jira/browse/FLINK-12861 Project: Flink Issue Type: Sub-task