@Override
protected void testProgram() throws Exception {
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
DataSet<Record> initialInput = env.readFile(new PointInFormat(), this.dataPath).setParallelism(1);
IterativeDataSet<Record> iteration = initialInput.iterate(2);
DataSet<Record> result = iteration.union(iteration).map(new IdentityMapper());