Search code examples
apache-flinkflink-streamingflink-sql

Need some examples for the flink-sql streaming process

Need some examples for the flink-sql streaming process. Both for the kafka source and database source.

Solution

  • There are many good examples in Ververica's training for Flink SQL -- https://github.com/ververica/sql-training. These examples use a Kafka source.

    Support for database sources is currently being developed. Flink 1.11 will add support for JDBC (Postgres) catalogs.