There is a terasort implementation with deprecated API. https://github.com/apache/flink/blob/master/flink-tests/src/test/java/org/apache/flink/test/recordJobs/sort/TeraSort.java
AFAIK, there is no implementation with current API. Regards, Chiwan Park > On Jun 4, 2015, at 12:17 AM, Bill Sparks <jspa...@cray.com> wrote: > > Just asking, is there an implementation of terasort for flink? > > Regards, > Bill. > -- > Jonathan (Bill) Sparks > Software Architecture > Cray Inc.