Looking at the program on Pastebin, there are some things that look not
right. I would be surprised if this program executes at all.
In particular, you are referring to outside distributed data sets inside
the filter function. You are calling collect() in every filter function,
which actually trig
Hi,
which version of Flink are you working with?
The master (0.9-SNAPSHOT) has a RichFilterFunction [1].
Best, Fabian
[1]
https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/functions/RichFilterFunction.java
2015-06-16 23:52 GMT+02:00 Vinh June :
>
