flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ramana Uppala <ramana.upp...@capitalone.com>
Subject Flink sql nested elements
Date Thu, 04 Jun 2020 19:34:36 GMT
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