flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Leonard Xu <xbjt...@gmail.com>
Subject Re: Flink sql nested elements
Date Fri, 05 Jun 2020 04:49:28 GMT
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 <ramana.uppala@capitalone.com> 写道:
> 
> 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.SqlParserPos.sum(SqlParserPos.java:226)
> 	at org.apache.calcite.sql.SqlIdentifier.getComponent(SqlIdentifier.java:232)
> 	at org.apache.calcite.sql.validate.DelegatingScope.fullyQualify(DelegatingScope.java:416)
> 	at org.apache.calcite.sql.validate.SqlValidatorImpl$Expander.visit(SqlValidatorImpl.java:5733)
> 	at org.apache.calcite.sql.validate.SqlValidatorImpl$Expander.visit(SqlValidatorImpl.java:5718)
> 	at org.apache.calcite.sql.SqlIdentifier.accept(SqlIdentifier.java:317)
> 
> Example Schema:
> ROW<`col1` VARCHAR(2147483647), `postalAddress` ROW<`addressLine1` VARCHAR(2147483647),
`addressLine2` VARCHAR(2147483647), `addressLine3` VARCHAR(2147483647)>>
> 
> Example SQL:
> insert into CSVSink
> select
> col1,
> postalAddress.addressLine1 as address
> from myStream
> 
> In Flink SQL, How to select nested elements ?
> 


Mime
View raw message