flink sql嵌套元素avro

92dk7w1h  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(234)

我有一个包含嵌套结构的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中,如何选择嵌套元素?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题