[
https://issues.apache.org/jira/browse/BEAM-8888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16991463#comment-16991463
]
Julien Tournay edited comment on BEAM-8888 at 12/9/19 10:08 AM:
----------------------------------------------------------------
Yeah looking at the code it seems just not implemented. AFAIK it is
undocumented.
Not sure if it is meant to be supported at some point but at the very least it
would be nice to have a more explicit error message.
Also _a few_ built in logical types are supported which makes the exception
even more confusing.
was (Author: jto):
Yeah looking at the code it seems just not implemented. AFAIK it is
undocumented.
Not sure if it is meant to be supported at some point but at the very least it
would be nice to have a more explicit error message.
> BeamSQL does not support LogicalType
> ------------------------------------
>
> Key: BEAM-8888
> URL: https://issues.apache.org/jira/browse/BEAM-8888
> Project: Beam
> Issue Type: Improvement
> Components: dsl-sql
> Reporter: Julien Tournay
> Priority: Major
>
> When running a BeamSQL query in a row with a Schema that contains a logical
> type a NPE is thrown with the following cause:
> {{}}{{ Cause: java.lang.NullPointerException:}}
> {{[info] at
> org.apache.beam.repackaged.sql.org.apache.calcite.sql.type.SqlTypeFactoryImpl.createSqlType(SqlTypeFactoryImpl.java:45)}}
> {{[info] at
> org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils.toRelDataType(CalciteUtils.java:278)}}
> {{[info] at
> org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils.toRelDataType(CalciteUtils.java:285)}}
> {{[info] at
> org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils.lambda$toCalciteRowType$0(CalciteUtils.java:260)}}
> {{[info] at
> java.util.stream.Streams$RangeIntSpliterator.forEachRemaining(Streams.java:110)}}
>
> This is because {{CalciteUtils.toSqlTypeName}} returns null in the general
> case if the type is Logical.
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)