Thanks Robin and Aniket for the suggestions you have given.
Will try and update on the same.
Thanks,
Elakiya
On Fri, Oct 20, 2023 at 2:34 AM Robin Moffatt wrote:
> CTEs are supported, you can see an example in the docs [1] [2]. In the
> latter doc, it also says
>
> > CTEs are supported in View
CTEs are supported, you can see an example in the docs [1] [2]. In the
latter doc, it also says
> CTEs are supported in Views, CTAS and INSERT statement
So I'm just guessing here, but your SQL doesn't look right.
The CTE needs to return a column called `pod`, and the `FROM` clause for
the `SELECT
cte1 AS a, cte2 as b .
);
Hope this helps you.
Regards,
Aniket Sule
From: elakiya udhayanan
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
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 statemen
