RocMarshal commented on code in PR #23379:
URL: https://github.com/apache/flink/pull/23379#discussion_r1321600006
##########
flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgramUtils.java:
##########
@@ -183,7 +183,8 @@ public static Pipeline getPipelineFromProgram(
throw generateException(
program,
- "The program plan could not be fetched - the program aborted
pre-maturely.",
+ "The program plan could not be fetched - the program aborted
pre-maturely. "
+ + "The root cause may be that the main method doesn't
call env.execute().",
Review Comment:
It looks like a reminder to the starter, Do we need to add env.
executeAsync() as well ？
##########
flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgramUtils.java:
##########
@@ -183,7 +183,8 @@ public static Pipeline getPipelineFromProgram(
throw generateException(
program,
- "The program plan could not be fetched - the program aborted
pre-maturely.",
+ "The program plan could not be fetched - the program aborted
pre-maturely. "
+ + "The root cause may be that the main method doesn't
call env.execute().",
Review Comment:
It looks like a reminder to the starter, Do we need to add env.
executeAsync() as well ？
--
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
