Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4649#discussion_r161799381 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java --- @@ -624,6 +633,10 @@ public long getLoopTimeout(Integer vertexID) { return iterationSourceSinkPairs; } + public Map<Tuple2<Integer, Integer>, Integer> getUniqueEdgeMap() { --- End diff -- This shouldn't be exposed
---