github-actions[bot] commented on issue #10808: URL: https://github.com/apache/dolphinscheduler/issues/10808#issuecomment-1176008575
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/dolphinscheduler/issues?q=is%3Aissue) and found no similar issues. ### What happened Use the dolphin scheduler to schedule flinksql, the table building statement can be executed normally, and the insert statement will report an error Error message: TaskLogLogger-class org.apache.dolphinscheduler.plugin.task.flink.FlinkTask:[63] - -> [31;1m[ERROR] Could not execute SQL statement. Reason: java.lang.IllegalStateException: No Executor found. Please make sure to export the HADOOP_CLASSPATH environment variable or have hadoop in your classpath. For more information refer to the "Deployment" section of the official Apache Flink documentation. [0m Shutting down the session... done. ### What you expected to happen Write a more detailed flinksql scheduling process, including the version of flink and the required environment ### How to reproduce Create three tables in MySQL with the same fields, insert data into two tables, and then write flinksql. Similarly, create three identical tables and associate them with the mysql table. Then query the two tables with data and insert them into the third table without data. Such flinksql After writing, put it on the dolphin scheduler for scheduling ### Anything else none ### Version 3.0.0-beta-2 ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- 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]
