JinkunLiu opened a new issue, #540: URL: https://github.com/apache/flink-agents/issues/540
### Search before asking - [x] I searched in the [issues](https://github.com/apache/flink-agents/issues) and found nothing similar. ### Description When running the WorkflowMultipleAgentExample in local, the application fails to start due to a ValidationException. The example code attempts to create a table source using the 'format'='json' option: ```java // WorkflowMultipleAgentExample.java tableEnv.createTemporaryTable( "product_reviews", TableDescriptor.forConnector("filesystem") // ... .option("format", "json") // Requires flink-json on classpath // ... .build()); ``` However, the flink-json dependency is not explicitly declared in examples/pom.xml (or ide-support/pom.xml), cause finding for the JSON format factory failed. ### How to reproduce 1. Run the main method of class `org.apache.flink.agents.examples.WorkflowMultipleAgentExample` in IDE. 2. The execution fails with the exception below. ### Stack Trace ``` Exception in thread "main" org.apache.flink.table.api.ValidationException: Unable to create a source for reading table 'default_catalog.default_database.product_reviews'. ... Caused by: org.apache.flink.table.api.ValidationException: Could not find any format factory for identifier 'json' in the classpath. at org.apache.flink.connector.file.table.FileSystemTableSource.<init>(FileSystemTableSource.java:118) at org.apache.flink.connector.file.table.FileSystemTableFactory.createDynamicTableSource(FileSystemTableFactory.java:78) at org.apache.flink.table.factories.FactoryUtil.createDynamicTableSource(FactoryUtil.java:241) ... ``` ### Version and environment version: main branch, after this commit [b03e69ad](https://github.com/apache/flink-agents/issues/527) ### Are you willing to submit a PR? - [x] 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]
