GreatEugenius opened a new issue, #560: URL: https://github.com/apache/flink-agents/issues/560
### Search before asking - [x] I searched in the [issues](https://github.com/apache/flink-agents/issues) and found nothing similar. ### Description ## Problem When submitting a Flink Agents Job to a Flink cluster following the quickstart guide, the job appears in the Flink Web UI with the default name "Flink Streaming Job". This makes it difficult to identify and manage multiple agent jobs running in the cluster. ## Proposed Solution Add a `job_name` parameter to the `execute()` method to allow users to specify a custom job name programmatically. **Current Implementation:** ```python def execute(self) -> None: """Execute agent individually.""" ``` **Proposed Implementation:** ```python def execute(self, job_name: str = None) -> None: """Execute agent individually. Args: job_name: Optional custom name for the Flink job. """ ``` ## Use Case Example ```python agent = DiagnosisAgent() agent.execute(job_name="Diagnosis Agent") ``` ### Are you willing to submit a PR? - [ ] I'm willing to submit a PR! -- 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]
