- Develop streaming or table api task under tasks folder
- use maven package jar, then submit to streaming platform.
- Set Flink and related install path in
env.sh
- Add SQL scripts under
src/main/resources/
with.sql
suffix, e.g,q1.sql
- Run your SQL via
./run.sh <sql-file-name>
, e.g../run.sh q1
- If the terminal returns the following output, it means the job is submitted successfully.
Starting execution of program
Job has been submitted with JobID d01b04d7c8f8a90798d6400462718743