[ 
https://issues.apache.org/jira/browse/BEAM-9613?focusedWorklogId=755483&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-755483
 ]

ASF GitHub Bot logged work on BEAM-9613:
----------------------------------------

                Author: ASF GitHub Bot
            Created on: 11/Apr/22 23:00
            Start Date: 11/Apr/22 23:00
    Worklog Time Spent: 10m 
      Work Description: pabloem commented on PR #14350:
URL: https://github.com/apache/beam/pull/14350#issuecomment-1095671672

   I verify (?)
   
   taking a look..




Issue Time Tracking
-------------------

    Worklog Id:     (was: 755483)
    Time Spent: 8h 20m  (was: 8h 10m)

> BigQuery IO not support convert double type for beam row
> --------------------------------------------------------
>
>                 Key: BEAM-9613
>                 URL: https://issues.apache.org/jira/browse/BEAM-9613
>             Project: Beam
>          Issue Type: Bug
>          Components: io-java-gcp
>    Affects Versions: 2.28.0
>            Reporter: MAKSIM TSYGAN
>            Priority: P3
>          Time Spent: 8h 20m
>  Remaining Estimate: 0h
>
> If execute query with double columnĀ  via BigQueryIO.readFrom(), I get 
> exception:
> Caused by: java.lang.UnsupportedOperationException: Converting BigQuery type 
> 'class java.lang.Double' to 'FieldType\{typeName=DOUBLE, nullable=true, 
> logicalType=null, collectionElementType=null, mapKeyType=null, 
> mapValueType=null, rowSchema=null, metadata={}}' is not supported
>  at 
> org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.toBeamValue(BigQueryUtils.java:532)
>  at 
> org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.toBeamRowFieldValue(BigQueryUtils.java:483)
>  at 
> org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.lambda$toBeamRow$6(BigQueryUtils.java:469)
>  at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
>  at 
> java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1382)
>  at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
>  at 
> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
>  at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
>  at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
>  at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566)
>  at 
> org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.toBeamRow(BigQueryUtils.java:470)



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to