Hi, Collecting results locally (e.g., for unit testing) is possible in the DataSet API by using "LocalCollectionOutputFormat", as described in the programming guide: https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/programming_guide.html#collection-data-sources-and-sinks
Can something similar be done for the DataStream API? Thanks, Filipe