wenjin272 commented on code in PR #570:
URL: https://github.com/apache/flink-agents/pull/570#discussion_r2959500784
##########
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:
The job name is not passed to the underlying Flink execution environment.
--
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]
