flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java [142:157]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        public OperatorCoordinator create(Context context) {
            SharedProgressAligner sharedProgressAligner =
                    SharedProgressAligner.getOrCreate(
                            iterationId,
                            totalHeadParallelism,
                            context,
                            () ->
                                    Executors.newSingleThreadScheduledExecutor(
                                            runnable -> {
                                                Thread thread = new Thread(runnable);
                                                thread.setName(
                                                        "SharedProgressAligner-" + iterationId);
                                                return thread;
                                            }));
            return new HeadOperatorCoordinator(context, sharedProgressAligner);
        }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-ml-iteration/flink-ml-iteration-1.15/src/main/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinator.java [141:156]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        public OperatorCoordinator create(Context context) {
            SharedProgressAligner sharedProgressAligner =
                    SharedProgressAligner.getOrCreate(
                            iterationId,
                            totalHeadParallelism,
                            context,
                            () ->
                                    Executors.newSingleThreadScheduledExecutor(
                                            runnable -> {
                                                Thread thread = new Thread(runnable);
                                                thread.setName(
                                                        "SharedProgressAligner-" + iterationId);
                                                return thread;
                                            }));
            return new HeadOperatorCoordinator(context, sharedProgressAligner);
        }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -