Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6129#discussion_r194696659 --- Diff: flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/AggregatorsITCase.java --- @@ -170,12 +162,12 @@ public void testAggregatorWithParameterForIterate() throws Exception { new NegativeElementsConvergenceCriterion()); DataSet<Integer> updatedDs = iteration.map(new SubtractOneMapWithParam()); - iteration.closeWith(updatedDs).writeAsText(resultPath); - env.execute(); + List<Integer> result = iteration.closeWith(updatedDs).collect(); + Collections.sort(result); --- End diff -- yes
---