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.

Reply via email to