Hi Dawid,
This issue has been resolved.
>From our debugging we found out that Calcite parser was able to resolve the
>nested elements as expected. But, expecting case to match with the schema. Our
>SQL select field case and schema field case was not matching in this scenario.
>After fixing sql
Hi Ramana,
Could you help us with a way to reproduce the behaviour? I could not
reproduce it locally. The code below works for me just fine:
|StreamExecutionEnvironment exec =
StreamExecutionEnvironment.getExecutionEnvironment();||
||StreamTableEnvironment tEnv = StreamTableEnvironment.create(||
Hi Leonard,
We are using Flink 1.10 version and I can not share the complete schema but
it looks like below in Hive Catalog,
flink.generic.table.schema.1.data-type ROW<`col1` VARCHAR(2147483647),
`postalAddress` ROW<`addressLine1` VARCHAR(2147483647), `addressLine2`
VARCHAR(2147483647), `addressL
