RE: Flink SQL exception on using cte

[Aniket Sule]

Hello,
I have been able to use queries with cte in this syntax –
INSERT INTO t1
      WITH cte1 AS (SELECT
                   ....),
                                 cte2 AS (SELECT
                   ....)
                               (SELECT
                  *
              FROM
                  cte1 AS a, cte2 as b .....
              );

Hope this helps you.

Regards,
Aniket Sule

From: elakiya udhayanan <laks....@gmail.com>
Sent: Thursday, October 19, 2023 3:04 AM
To: user@flink.apache.org
Subject: Flink SQL exception on using cte

CAUTION:External email. Do not click or open attachments unless you know and 
trust the sender.

Hi Team,

I have a Flink job which uses the upsert-kafka connector to consume the events 
from two different Kafka topics (confluent avro serialized) and write them to 
two different tables (in Flink's memory using the Flink's SQL DDL statements).

I want to correlate them using the SQL join statements and for this I am trying 
to use the cte expressions like below (sample): But getting  exception as below

 org.apache.flink.table.api.SqlParserException: SQL parse failed. Incorrect 
syntax near the keyword 'INSERT'


WITH p1 AS ( SELECT empId FROM employee )

 FROM p1

INSERT INTO correlate

SELECT pod;
Please let me know if queries with cte are supported in Apache Flink.

Thanks,
Elakiya
Caution: External email. Do not click or open attachments unless you know and 
trust the sender.