davidradl commented on code in PR #24618: URL: https://github.com/apache/flink/pull/24618#discussion_r1582722531
########## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/LineageGraph.java: ########## @@ -20,13 +20,12 @@ package org.apache.flink.streaming.api.lineage; import org.apache.flink.annotation.PublicEvolving; -import org.apache.flink.streaming.api.graph.StreamGraph; import java.util.List; /** - * Job lineage is built according to {@link StreamGraph}, users can get sources, sinks and - * relationships from lineage and manage the relationship between jobs and tables. + * Job lineage graph that users can get sources, sinks and relationships from lineage and manage the Review Comment: Can we add documentation please, so the user will know how to use this (very needed) functionality. I am wondering why we have source and sinks rather than just nodes. I assume a sink could be a source - so could be in both current lists. -- 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. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org