flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vino yang <yanghua1...@gmail.com>
Subject Re: Initializing mapstate hangs
Date Sat, 20 Oct 2018 10:29:41 GMT
Hi Ahmad,

Can you try to dump thread info from the Task Manager's JVM instance?

Thanks, vino.

Ahmad Hassan <ahmad.hassan@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 <yanghua1127@gmail.com> wrote:
>
> Hi Ahmad,
>
> Which version of Flink do you use?
>
> Thanks, vino.
>
> Ahmad Hassan <ahmad.hassan@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.
>>
>

Mime
View raw message