JunRuiLee commented on code in PR #25798:
URL: https://github.com/apache/flink/pull/25798#discussion_r1889726647
##########
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/AccessExecutionGraph.java:
##########
@@ -47,6 +47,13 @@ public interface AccessExecutionGraph extends
JobStatusProvider {
*/
String getJsonPlan();
+ /**
+ * Returns the stream graph as a JSON string.
+ *
+ * @return stream graph as a JSON string
+ */
+ String getJsonStreamGraph();
Review Comment:
ditto
##########
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/ExecutionPlanSchedulingContext.java:
##########
@@ -58,4 +58,11 @@ int getConsumersMaxParallelism(
* @return the number of pending operators.
*/
int getPendingOperatorCount();
+
+ /**
+ * Retrieves the JSON representation of the stream graph for the original
job.
+ *
+ * @return the JSON representation of the stream graph.
+ */
+ String getJsonStreamGraph();
Review Comment:
getStreamGraphJson()
Add more comments to clarify the JSON pattern if a job graph is submitted.
--
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
