I am working through the book Stream Processing with Apache Flink by Fabian Hueske and Vasiliki Kalavri.
The book includes an example Flink application and I want to figure out how to run the file. It is a scala file located here in their github repo.
Must I turn it into a JAR file before I run it? If so, how do I convert the file to JAR?
CodePudding user response：
Except for SQL queries submitted with Flink‘s SQL client, a user needs to package a JAR file. Usually, a Flink program file can be packaged using a Maven or Gradle project: