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
