Thanks for reporting this Tao - could you share what the type of your input PCollection is?
On Tue, Mar 2, 2021 at 9:33 AM Tao Li <[email protected]> wrote: > Hi all, > > > > I was following the instructions from this doc to play with ZetaSQL > https://beam.apache.org/documentation/dsls/sql/overview/ > > > > The query is really simple: > > > > options.as > (BeamSqlPipelineOptions.class).setPlannerName("org.apache.beam.sdk.extensions.sql.zetasql.ZetaSQLQueryPlanner") > > input.apply(SqlTransform.query("SELECT * from PCOLLECTION")) > > > > I am seeing this error with ZetaSQL : > > > > Exception in thread "main" java.lang.UnsupportedOperationException: > Unknown Calcite type: INTEGER > > at > org.apache.beam.sdk.extensions.sql.zetasql.ZetaSqlCalciteTranslationUtils.toZetaSqlType(ZetaSqlCalciteTranslationUtils.java:114) > > at > org.apache.beam.sdk.extensions.sql.zetasql.SqlAnalyzer.addFieldsToTable(SqlAnalyzer.java:359) > > at > org.apache.beam.sdk.extensions.sql.zetasql.SqlAnalyzer.addTableToLeafCatalog(SqlAnalyzer.java:350) > > at > org.apache.beam.sdk.extensions.sql.zetasql.SqlAnalyzer.lambda$createPopulatedCatalog$1(SqlAnalyzer.java:225) > > at > com.google.common.collect.ImmutableList.forEach(ImmutableList.java:406) > > at > org.apache.beam.sdk.extensions.sql.zetasql.SqlAnalyzer.createPopulatedCatalog(SqlAnalyzer.java:225) > > at > org.apache.beam.sdk.extensions.sql.zetasql.ZetaSQLPlannerImpl.rel(ZetaSQLPlannerImpl.java:102) > > at > org.apache.beam.sdk.extensions.sql.zetasql.ZetaSQLQueryPlanner.convertToBeamRelInternal(ZetaSQLQueryPlanner.java:180) > > at > org.apache.beam.sdk.extensions.sql.zetasql.ZetaSQLQueryPlanner.convertToBeamRel(ZetaSQLQueryPlanner.java:168) > > at > org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv.parseQuery(BeamSqlEnv.java:114) > > at > org.apache.beam.sdk.extensions.sql.SqlTransform.expand(SqlTransform.java:140) > > at > org.apache.beam.sdk.extensions.sql.SqlTransform.expand(SqlTransform.java:86) > > > > This query works fine when using Calcite (by just removing setPlannerName > call). Am I missing anything here? For example I am specifying > 'com.google.guava:guava:23.0' as the dependency. > > > > Thanks! > > > > >
