flink-demo minimum code just run flink-ds-connector DataStream API usage kafka es jdbc file row string parquet avro avro custom avro flink-sql-connector SQL usage print blackhole datagen jdbc scan lookup batch sink streaming sink es batch sink streaming sink hbase lookup scan batch sink streaming sink kafka streaming sink scan source upsert-kafka streaming sink scan source filesystem streaming sink how to run sql cd flink-sql-parser mvn install -Dskip.Tests run SqlJobSubmitter with --sql.path your sql file path