Hi, I was able to reproduce the issue and filed a bug report: https://issues.apache.org/jira/browse/FLINK-1046
Thank you for reporting the issue! Robert On Tue, Aug 12, 2014 at 8:36 PM, Fegaras, Leonidas <[email protected]> wrote: > Hi, > There is a problem with custom accumulators in local and cluster modes. > When I run the EmptyFieldsCountAccumulator example: > > cd flink-0.6-incubating > > flink-dist/target/flink-0.6-incubating-bin/flink-0.6-incubating/bin/start-local.sh > flink-dist/target/flink-0.6-incubating-bin/flink-0.6-incubating/bin/flink > run > flink-examples/flink-java-examples/target/flink-java-examples-0.6-incubating.jar > -c org.apache.flink.example.java.relational.EmptyFieldsCountAccumulator > > the job manager finishes but the program doesn't terminate. > Is this a bug? > Leonidas >
