[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15144455#comment-15144455 ]
Martin Liesenberg commented on FLINK-2032: ------------------------------------------ Is there still work to do here? If so I'd love any pointers which modules do not need the env.execute any more. > Migrate integration tests from temp output files to collect() > ------------------------------------------------------------- > > Key: FLINK-2032 > URL: https://issues.apache.org/jira/browse/FLINK-2032 > Project: Flink > Issue Type: Task > Components: Tests > Affects Versions: 0.9 > Reporter: Fabian Hueske > Priority: Minor > Labels: starter > > Most of Flink's integration tests that execute full Flink programs and check > their results are implemented by writing results to temporary output file and > comparing the content of the file to a provided set of expected Strings. > Flink's test utils make this quite comfortable and hide a lot of the > complexity of this approach. Nonetheless, this approach has a few drawbacks: > - increased latency by going through disk > - comparison is on String representation of objects > - depends on the file system > Since Flink's {{collect()}} feature was added, the temp file approach is not > the best approach anymore. Instead, tests can collect the result of a Flink > program directly as objects and compare these against a set of expected > objects. > It would be good to migrate the existing test base to use {{collect()}} > instead of temporary output files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)