Re: [DISCUSS] Set default planner for SQL Client to Blink planner in 1.10 release

2020-01-04 Thread Benchao Li
+1 We have used blink planner since 1.9.0 release in our production environment, and it behaves really impressive. Hequn Cheng 于2020年1月5日周日 下午1:58写道: > +1 to make blink planner as the default planner for SQL Client, hence we > can give the blink planner a bit more exposure. > > Best, Hequn > >

Re: [DISCUSS] Set default planner for SQL Client to Blink planner in 1.10 release

2020-01-04 Thread Hequn Cheng
+1 to make blink planner as the default planner for SQL Client, hence we can give the blink planner a bit more exposure. Best, Hequn On Fri, Jan 3, 2020 at 6:32 PM Jark Wu wrote: > Hi Benoît, > > Thanks for the reminder. I will look into the issue and hopefully we can > target it into 1.9.2 and

[ANNOUNCE] Weekly Community Update 2020/01

2020-01-04 Thread Hequn Cheng
Dear community, Happy new year! Wishing you a new year rich with the blessings of love, joy, warmth, and laughter. Wish Flink will get better and better. Nice to share this week’s community digest with an update on Flink-1.10.0, a proposal to set blink planner as the default planner for SQL Clien

Re: Flink task node shut it self off.

2020-01-04 Thread John Smith
It seems to have happened again... Here is a screen shot of the system metrics for that day on that particular node https://www.dropbox.com/s/iudn7z2fvvy7vb8/flink-node.png?dl=0 On Fri, 3 Jan 2020 at 12:19, John Smith wrote: > Well there was this huge IO wait like over 140% spike. IO wait

Stateful functions and modules

2020-01-04 Thread Dan Pettersson
Hi, What is the preferred way to expose functions (FunctionTypes) between modules? For example lets say i have the following maven modules: -> common -> statistics -> persister -> tradematching and I have some FunctionTypes in common and persister module that should be reach from all modules.

Re: Yarn Kerberos issue

2020-01-04 Thread Rong Rong
Hi Juan, Chesnay was right. If you are using CLI to launch your session cluster based on the document [1], you following the instruction to use kinit [2] first seems to be one of the right way to go. Another way of approaching it is to setup the kerberos settings in the flink-conf.yaml file [3]. F