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
