Re: Initializing mapstate hangs

2018-10-23 Thread Ahmad Hassan
;> >> at java.lang.Thread.run(Thread.java:745) >> >> >> >> >> On Sat, 20 Oct 2018 at 11:29, vino yang wrote: >> >>> Hi Ahmad, >>> >>> Can you try to dump thread info from the Task Manager's JVM instance? >>>

Re: Initializing mapstate hangs

2018-10-23 Thread Dawid Wysakowicz
<mailto:yanghua1...@gmail.com>> wrote: > >> Hi Ahmad, >> >> Which version of Flink do you use? >> >> Thanks, vino. >> >> Ahmad Hassan > <mailto:ahmad.has...@gmail.com>> 于201

Re: Initializing mapstate hangs

2018-10-22 Thread Alexander Smirnov
;> Can you try to dump thread info from the Task Manager's JVM instance? >> >> Thanks, vino. >> >> Ahmad Hassan 于2018年10月20日周六 下午4:24写道： >> >>> Flink 1.6.0. Valuestate initialises successful but mapstate hangs >>> >>> Regards >>

Re: Initializing mapstate hangs

2018-10-22 Thread Ahmad Hassan
18年10月20日周六 下午4:24写道： > >> Flink 1.6.0. Valuestate initialises successful but mapstate hangs >> >> Regards >> >> On 20 Oct 2018, at 02:55, vino yang wrote: >> >> Hi Ahmad, >> >> Which version of Flink do you use? >> >> Thanks,

Re: Initializing mapstate hangs

2018-10-20 Thread vino yang
i Ahmad, > > Which version of Flink do you use? > > Thanks, vino. > > Ahmad Hassan 于2018年10月19日周五 下午11:32写道： > >> Hi, >> >> Initializing mapstate hangs in window function. However if i use >> valuestate then it is initialized succcessfully. I am using roc

Re: Initializing mapstate hangs

2018-10-20 Thread Ahmad Hassan
Flink 1.6.0. Valuestate initialises successful but mapstate hangs Regards > On 20 Oct 2018, at 02:55, vino yang wrote: > > Hi Ahmad, > > Which version of Flink do you use? > > Thanks, vino. > > Ahmad Hassan 于2018年10月19日周五 下午11:32写道： >> Hi, >> &

Re: Initializing mapstate hangs

2018-10-19 Thread vino yang
Hi Ahmad, Which version of Flink do you use? Thanks, vino. Ahmad Hassan 于2018年10月19日周五 下午11:32写道： > Hi, > > Initializing mapstate hangs in window function. However if i use > valuestate then it is initialized succcessfully. I am using rocksdb to > store the state. &

Initializing mapstate hangs

2018-10-19 Thread Ahmad Hassan
Hi, Initializing mapstate hangs in window function. However if i use valuestate then it is initialized succcessfully. I am using rocksdb to store the state. public class MyWindowFunction extends RichWindowFunction { private transient MapStateDescriptor productsDescriptor = new MapStateDescriptor