Re: [DISCUSS] Releasing Flink 1.8.3

2019-11-09 Thread Hequn Cheng
Hi Jincheng, Thanks for kicking this discussion off! +1 to the 1.8.3 release as it would be nice to have these important fixes and also two months have passed since the last release. Besides, I wonder if I can be the release manager of 1.8.3 or work with you together @Jincheng? It's always excit

[jira] [Created] (FLINK-14685) ZooKeeperCheckpointIDCounter forever broken if once loss connection with ZK

2019-11-09 Thread Zili Chen (Jira)
Zili Chen created FLINK-14685: - Summary: ZooKeeperCheckpointIDCounter forever broken if once loss connection with ZK Key: FLINK-14685 URL: https://issues.apache.org/jira/browse/FLINK-14685 Project: Flink

Re: [ANNOUNCE] Jark Wu is now part of the Flink PMC

2019-11-09 Thread Jark Wu
Thanks everyone! Really happy to be part of such an enthusiastic community and working with all of you on such a great project. Best, Jark On Sat, 9 Nov 2019 at 06:28, Becket Qin wrote: > Congrats, Jark! > > On Sat, Nov 9, 2019 at 2:33 AM Bowen Li wrote: > > > Well deserved. Congrats, Jark! >

Re: [DISCUSS] Releasing Flink 1.8.3

2019-11-09 Thread Jark Wu
+1 for the 1.8.3 release and for Hequn being the RM. Thanks Jincheng for the effort and help on the releasing. Best, Jark On Sat, 9 Nov 2019 at 15:59, Hequn Cheng wrote: > Hi Jincheng, > > Thanks for kicking this discussion off! > > +1 to the 1.8.3 release as it would be nice to have these im

Re: [VOTE] FLIP-69: Flink SQL DDL Enhancement

2019-11-09 Thread Jark Wu
+1 from my side. They are useful features. Best, Jark On Fri, 8 Nov 2019 at 16:42, Danny Chan wrote: > +1(non-binding), nice job, Terry ~ > > Best, > Danny Chan > 在 2019年11月5日 +0800 PM10:32,dev@flink.apache.org,写道: > > > > +1 to the long missing feature in Flink SQL. >

stream processing and bulk updates to multiple sinks

2019-11-09 Thread Vijay Srinivasaraghavan
Hello, I have a need to process events in near real-time that are generated from various upstream sources and are currently stored in Kafka. I want to build a pipeline that reads the data as a continuous stream, enrich the events and finally store it in both ClickHouse and Kafka sinks.  To get a

Re: [ANNOUNCE] Jark Wu is now part of the Flink PMC

2019-11-09 Thread vino yang
Congratulations, Jark. Best, Vino Leonard Xu 于2019年11月8日周五 下午8:40写道: > Congratulations, Jark. > Thanks for your contribution and help. > > Best, > Leonard Xu > > > On 2019年11月8日, at 下午6:37, Yun Gao wrote: > > > > Congratulations Jark! > > > > Best, > > Yun > > > > > > -

Re:[ANNOUNCE] Jark Wu is now part of the Flink PMC

2019-11-09 Thread Matt Wang
Congratulations, Jark! --- Best, Matt Wang On 11/8/2019 17:51,jincheng sun wrote: Hi all, On behalf of the Flink PMC, I'm happy to announce that Jark Wu is now part of the Apache Flink Project Management Committee (PMC). Jark has been a committer since February 2017. He has been very active

Re: [DISCUSS] Releasing Flink 1.8.3

2019-11-09 Thread Yu Li
+1 for starting the 1.8.3 release cycle. Thanks for watching and driving this forward jincheng! Also +1 for Hequn to be the 1.8.3 RM. Best Regards, Yu On Sat, 9 Nov 2019 at 23:36, Jark Wu wrote: > +1 for the 1.8.3 release and for Hequn being the RM. > Thanks Jincheng for the effort and help o

Re: [VOTE] FLIP-79: Flink Function DDL Support (1.10 Release Feature Only)

2019-11-09 Thread Yu Li
Thanks for driving this Peter! I agree it would be great if we could include this feature in 1.10. However, FWIW, since we are following the time-based release policy [1] and 1.10 release is approaching its feature freeze (planned to be at the end of November) [2], I'm a little bit concerned about

Re: [VOTE] FLIP-79: Flink Function DDL Support (1.10 Release Feature Only)

2019-11-09 Thread Peter Huang
Hi Xuefu, Thanks for the feedback. I think JVM is used as we don't need to distinguish scala/java based function for now. But as DDL is an important interface for Flink users. I think we should make it extendable for the future. As you said, It is JAVA and SCALA are in the LANGUAGE level rather t

Re: [VOTE] FLIP-79: Flink Function DDL Support (1.10 Release Feature Only)

2019-11-09 Thread Peter Huang
Hi Yu, Thanks for your reminder about the timeline of delivering the basic function DDL in release 1.10. As I replied to Xuefu, the "CREATE FUNCTION" and "DROP FUNCTION" can relatively easy achieve by revising the existing PR. Definitely, I probably need to start to work on a basic version of PR f

[RESULT][VOTE] FLIP-69: Flink SQL DDL Enhancement

2019-11-09 Thread Terry Wang
Hi all, The voting time for FLIP-69 has passed. I'm closing the vote now. There were seven +1 votes, 3 of which are binding: - Bowen Li (binding) - Jark Wu (binding) - Kurt Young (binding) - Xuefu Z (non-binding) - Peter Huang (non-binding) - Jingsong Li (non-binding) - Danny Chan (non-binding)

[jira] [Created] (FLINK-14686) Flink SQL DDL Enhancement

2019-11-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-14686: -- Summary: Flink SQL DDL Enhancement Key: FLINK-14686 URL: https://issues.apache.org/jira/browse/FLINK-14686 Project: Flink Issue Type: New Feature Compo

[jira] [Created] (FLINK-14687) Add database related ddl support to FLINK-SQL-Parser

2019-11-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-14687: -- Summary: Add database related ddl support to FLINK-SQL-Parser Key: FLINK-14687 URL: https://issues.apache.org/jira/browse/FLINK-14687 Project: Flink Issue Type:

[jira] [Created] (FLINK-14688) Add table related

2019-11-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-14688: -- Summary: Add table related Key: FLINK-14688 URL: https://issues.apache.org/jira/browse/FLINK-14688 Project: Flink Issue Type: Sub-task Reporter: Terr

[jira] [Created] (FLINK-14689) Add catalog related DDLs support in SQL Parser

2019-11-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-14689: -- Summary: Add catalog related DDLs support in SQL Parser Key: FLINK-14689 URL: https://issues.apache.org/jira/browse/FLINK-14689 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-14690) Support catalog related DDLs in TableEnvironment

2019-11-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-14690: -- Summary: Support catalog related DDLs in TableEnvironment Key: FLINK-14690 URL: https://issues.apache.org/jira/browse/FLINK-14690 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-14691) Support database related DDLs in TableEnvironment

2019-11-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-14691: -- Summary: Support database related DDLs in TableEnvironment Key: FLINK-14691 URL: https://issues.apache.org/jira/browse/FLINK-14691 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-14692) Support Table related DDLs in TableEnvironment

2019-11-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-14692: -- Summary: Support Table related DDLs in TableEnvironment Key: FLINK-14692 URL: https://issues.apache.org/jira/browse/FLINK-14692 Project: Flink Issue Type: Sub-ta

Re: [VOTE] FLIP-79: Flink Function DDL Support (1.10 Release Feature Only)

2019-11-09 Thread Kurt Young
+1 (binding) Best, Kurt On Sun, Nov 10, 2019 at 12:25 PM Peter Huang wrote: > Hi Yu, > > Thanks for your reminder about the timeline of delivering the basic > function DDL in release 1.10. > As I replied to Xuefu, the "CREATE FUNCTION" and "DROP FUNCTION" can > relatively easy achieve by revis

Re: [ANNOUNCE] Jark Wu is now part of the Flink PMC

2019-11-09 Thread Yun Tang
Congratulations, Jark Best Yun Tang On 11/10/19, 10:40 AM, "vino yang" wrote: Congratulations, Jark. Best, Vino Leonard Xu 于2019年11月8日周五 下午8:40写道: > Congratulations, Jark. > Thanks for your contribution and help. > > Best, > Leonard Xu >