qingfei1994 commented on code in PR #570:
URL: https://github.com/apache/flink-agents/pull/570#discussion_r2964305173
##########
api/src/main/java/org/apache/flink/agents/api/AgentsExecutionEnvironment.java:
##########
@@ -197,6 +197,20 @@ public AgentBuilder fromTable(Table input) {
*/
public abstract void execute() throws Exception;
+ /**
+ * Execute agent pipeline with a given job name.
+ *
+ * <p>This method triggers the execution of the configured agent pipeline
with the specified job
+ * name. For remote environments, the job name is passed to the underlying
Flink execution
+ * environment. The default implementation ignores the job name and
delegates to {@link
+ * #execute()}.
+ *
+ * @param jobName The name for the Flink job.
+ */
+ public void execute(String jobName) throws Exception {
+ execute();
Review Comment:
My first thought is to providing an optional execute with jobName method for
other execution environment like LocalExecutionEnvironment which doesn't
support executing with jobName, but since then I think I would just provide an
abstract method here.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
