Skip to content
A simple project used to submit a Flink SQL script
Java Shell TSQL
Branch: master
Clone or download
Latest commit ce45b21 Sep 2, 2019
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
src/main Add README and LICENSE Sep 2, 2019
.gitignore update Aug 30, 2019
LICENSE Add README and LICENSE Sep 2, 2019
README.md update Sep 2, 2019
env.sh update Sep 2, 2019
kafka-common.sh update Sep 2, 2019
kafka-consumer.sh initial commit Aug 13, 2019
pom.xml add source generator Aug 30, 2019
run.sh update Sep 2, 2019
source-generator.sh update Sep 2, 2019
start-kafka.sh update Sep 2, 2019
stop-kafka.sh update Sep 2, 2019

README.md

Flink SQL Submit

Currently, Flink 1.9 doesn't support to submit a DDL statement in SQL CLI, and also doesn't support to submit a SQL script. This is not convenient for walkthrough and demo. That's why I created a such a project.

How to use

  1. Set your Flink and Kafka install path in env.sh
  2. Add your SQL scripts under src/main/resources/ with .sql suffix, e.g, q1.sql
  3. Start all the service your job needed, including Flink, Kafka, and DataBases.
  4. Run your SQL via ./run.sh <sql-file-name>, e.g. ./run.sh q1
  5. 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

Others

You can follow my WeChat Subscription Account for more information about this project.

You can’t perform that action at this time.