Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3554#discussion_r106431288
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
---
@@ -1498,10 +1499,12 @@ public JobExecutionResult execute() throws
Exception {
*
* @param jobName
* Desired name of the job
+ * @param detached
+ * Whether to run the job in detached mode
* @return The result of the job execution, containing elapsed time and
accumulators.
* @throws Exception which occurs during job execution.
*/
- public abstract JobExecutionResult execute(String jobName) throws
Exception;
+ public abstract JobExecutionResult execute(String jobName, boolean
detached) throws Exception;
--- End diff --
this is a public method that you mustn't change; you have to add a
completely new method.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
