Hi Ahmad,
Can you try to dump thread info from the Task Manager's JVM instance?
Thanks, vino.
Ahmad Hassan <ahmad.has...@gmail.com> 于2018年10月20日周六 下午4:24写道：
> Flink 1.6.0. Valuestate initialises successful but mapstate hangs
>
> Regards
>
> On 20 Oct 2018, at 02:55, vino yang <yanghua1...@gmail.com> wrote:
>
> Hi Ahmad,
>
> Which version of Flink do you use?
>
> Thanks, vino.
>
> Ahmad Hassan <ahmad.has...@gmail.com> 于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.
>>
>> public class MyWindowFunction extends RichWindowFunction<Event, Payload,
>> Tuple, TimeWindow>
>> {
>> private transient MapStateDescriptor<String, String> productsDescriptor =
>> new MapStateDescriptor<>(
>> "mapState", String.class, String.class);
>>
>> @Override
>> public void apply(Tuple key, TimeWindow window, final Iterable<Event>
>> input,
>> final Collector<Payload> out)
>> {
>> // do something
>> }
>>
>> @Override
>> public void open(Configuration parameters) throws Exception
>> {
>> System.out.println("## open init window state ");
>> * MapState<String, String> state =
>> this.getRuntimeContext().getMapState(productsDescriptor); <<< program hangs
>> here*
>> System.out.println("## open window state " + state);
>> }
>> }
>>
>> Thanks for the help.
>>
>
