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.