flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ahmad Hassan <ahmad.has...@gmail.com>
Subject Re: Initializing mapstate hangs
Date Sat, 20 Oct 2018 08:24:41 GMT
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