Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4761#discussion_r154021028
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationHeadTask.java
---
@@ -223,8 +225,10 @@ private void readInitialSolutionSet(JoinHashMap<X>
solutionSet, MutableObjectIte
private SuperstepBarrier initSuperstepBarrier() {
SuperstepBarrier barrier = new
SuperstepBarrier(getUserCodeClassLoader());
- this.toSync.subscribeToEvent(barrier,
AllWorkersDoneEvent.class);
- this.toSync.subscribeToEvent(barrier, TerminationEvent.class);
+ TaskEventDispatcher taskEventDispatcher =
getEnvironment().getTaskEventDispatcher();
+ ResultPartitionID partitionId = this.toSync.getPartitionId();
--- End diff --
nit: remove `this`
---
