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, Ramna
Happy to hear you’ve resolved your problem, if you could post your SQL maybe
this question can get quicker response.
Flink SQL is case sensitive default and there had an issue to track[1], I think
it makes sense to add some specification in SQL section of docs.
Best,
Leonard Xu
[1] h
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
Hi，Ramana
For nested data type, Flink use dot (eg a.b.c) to visit nested elements. Your
SQL syntax looks right, which Flink version are you using? And could you post
your Avro Schema file and DDL ?
Best,
Leonard Xu
> 在 2020年6月5日，03:34，Ramana Uppala 写道：
>
> We have Avro schema that contains n
We have Avro schema that contains nested structure and when querying using
Flink SQL, we are getting below error.
Exception in thread "main" java.lang.AssertionError
at
org.apache.calcite.sql.parser.SqlParserPos.sum_(SqlParserPos.java:236)
at org.apache.calcite.sql.parser.SqlPars
