godfreyhe commented on a change in pull request #13742:
URL: https://github.com/apache/flink/pull/13742#discussion_r512657810
##########
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/processors/utils/TopologyGraph.java
##########
@@ -100,6 +100,9 @@ void unlink(ExecNode<?, ?> from, ExecNode<?, ?> to) {
* Calculate the maximum distance of the currently added nodes from the
nodes without inputs.
* The smallest distance is 0 (which are exactly the nodes without
inputs) and the distances of
* other nodes are the largest distances in their inputs plus 1.
+ *
+ * <p>Distance of a node is defined as the number of edges one needs to
go through from the
+ * nodes without inputs to this node.
*/
Map<ExecNode<?, ?>, Integer> calculateDistance() {
Review comment:
rename to calculateMaxDistance
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
