You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@beam.apache.org by Jeff Zhang <zj...@gmail.com> on 2023/04/24 08:41:29 UTC
Beam Sql parse error: Cannot find a matching Calcite SqlTypeName for Beam logical type: OneOf
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
Re: Beam Sql parse error: Cannot find a matching Calcite SqlTypeName for Beam logical type: OneOf
Posted by Andrew Pilloud via user <us...@beam.apache.org>.
It means SQL doesn't support the "OneOf" type.
On Mon, Apr 24, 2023 at 1:42 AM Jeff Zhang <zj...@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
>