Hey, I have found that open and close methods of streaming RichWindowFunctions are not called. I have the fix [1] as I did implement a fix for a similar issue some time ago, [2] sorry for not realizing it back then.
[1] https://github.com/apache/flink/pull/855 [2] https://issues.apache.org/jira/browse/FLINK-1956 I personally would not necessarily cancel the 0.9.0 release on this, from the looks of it I am the only one who currently needs this feature working for the Google Dataflow translator and I have a workaround in mind for that. But definitely a candidate 0.9.1.