A Flink application project using Scala and SBT.
Leverage g8 template from https://nightlies.apache.org/flink/flink-docs-release-1.3/quickstart/scala_api_quickstart.html
To run and test your application locally, you can just execute sbt run then select the main class that contains the Flink job .
To run unit test, you can just execute sbt test .
- Add more unit test
- Error handling of parsing / handleing issues
- Logging mechanism
- ...