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? >>> >>> Th

Re: Initializing mapstate hangs

2018-10-23 Thread Dawid Wysakowicz
t;mailto:yanghua1...@gmail.com>> wrote: > >> Hi Ahmad, >> >> Which version of Flink do you use? >> >> Thanks, vino. >> >> Ahmad Hassan > <mailto:ahmad.has...@gmail.com>> 于2018年10月19日周五 >

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
月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, vi

Re: Initializing mapstate hangs

2018-10-20 Thread vino yang
ad, > > 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

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