It means SQL doesn't support the "OneOf" type. On Mon, Apr 24, 2023 at 1:42 AM Jeff Zhang <zjf...@gmail.com> wrote:
> > Hi all, > > I got the following error when running sql: select * from PCOLLECTION, > what does this mean? > > > Exception in thread "main" > org.apache.beam.sdk.extensions.sql.impl.ParseException: Unable to parse > query select * from PCOLLECTION > at > org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner.convertToBeamRel(CalciteQueryPlanner.java:216) > at > org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv.parseQuery(BeamSqlEnv.java:112) > at > org.apache.beam.sdk.extensions.sql.SqlTransform.expand(SqlTransform.java:172) > at > org.apache.beam.sdk.extensions.sql.SqlTransform.expand(SqlTransform.java:110) > at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:548) > at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:499) > at org.apache.beam.sdk.values.PCollection.apply(PCollection.java:373) > at > io.zjffdu.demos.beam.KafkaRiskExample.readKafkaJson(KafkaRiskExample.java:151) > at io.zjffdu.demos.beam.KafkaRiskExample.main(KafkaRiskExample.java:169) > Caused by: > org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.tools.ValidationException: > java.lang.IllegalArgumentException: Cannot find a matching Calcite > SqlTypeName for Beam logical type: OneOf > at > org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.prepare.PlannerImpl.validate(PlannerImpl.java:226) > at > org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner.convertToBeamRel(CalciteQueryPlanner.java:184) > ... 8 more > Caused by: java.lang.IllegalArgumentException: Cannot find a matching > Calcite SqlTypeName for Beam logical type: OneOf > > -- > Best Regards > > Jeff Zhang >
