我有一个包含嵌套结构的avro模式,当使用flinksql进行查询时,我们得到以下错误。
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)
架构示例:
行< col1
瓦尔查尔(2147483647), postalAddress
行< addressLine1
瓦尔查尔(2147483647), addressLine2
瓦尔查尔(2147483647), addressLine3
瓦尔查尔(2147483647)>>
sql示例:
insert into CSVSink
select
col1,
postalAddress.addressLine1 as address
from myStream
在flinksql中,如何选择嵌套元素?
暂无答案!
目前还没有任何答案,快来回答吧!