flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Emmanuel <ele...@msn.com>
Subject bug? open() not getting called with RichWindowMapFunction
Date Sat, 23 May 2015 20:26:32 GMT

extending AbstractRichFunction gives access to the open function which is called at init if
I understand correctly.
That works fine with RichMapFunction, but with RichWindowMapFunction which also extends AbstractRichFunction
the open function never seems to get called.
I also tried extending AbstractRichFunction and implementing AbstractRichFunction but that
does not help with this.. so it seems like the open function is just never called when setting
up a mapWindow transform.
I'm using 0.9-milestone1
Is this a bug?Thanks    		 	   		  
View raw message