I have a use case where I need to retrieve metadata from a data lake using Flink SQL. Along the lines I create some simple selection statements as the following:

I need to enrich my data using reference tables and would like to use Flink SQL for this purpose. My reference tables are stored
in object storage using the Iceberg table format. To start, I am trying to create temporary tables in Flink SQL that project and
filter the original tables. Therefore along the lines, I have written the following SQL statements:

I have the below flink sql code

I’m trying to read Avro data with complex schema in Kafka topic. I have following schema:

I have my flink sql statement as follows

I had a sql-config.yaml file used with the now-removed -d <config file> option to configure Flink’s SQL client.