[ 
https://issues.apache.org/jira/browse/BEAM-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17547558#comment-17547558
 ] 

Kenneth Knowles commented on BEAM-6298:
---------------------------------------

This issue has been migrated to https://github.com/apache/beam/issues/19295

> Can not insert into BigQuery table that is not empty
> ----------------------------------------------------
>
>                 Key: BEAM-6298
>                 URL: https://issues.apache.org/jira/browse/BEAM-6298
>             Project: Beam
>          Issue Type: Bug
>          Components: dsl-sql
>    Affects Versions: 2.10.0
>            Reporter: Luat Nguyen
>            Priority: P3
>
> There is a Exception when I try to insert into BigQuery table that is not 
> empty.
> Example code Beam SQL:
> {code:java}
> BeamSqlRelUtils.toPCollection(pipeline, sqlEnv.parseQuery("INSERT INTO 
> D_CARD_LITE(DIM_ID) VALUES('xxxx')")){code}
> The exception messages as below:
> {code:java}
> java.lang.IllegalStateException: BigQuery table is not empty: 
> mydataset:samples.D_CARD_LITE.
>  at com.google.common.base.Preconditions.checkState(Preconditions.java:518)
>  at 
> org.apache.beam.sdk.io.gcp.bigquery.BigQueryHelpers.verifyTableNotExistOrEmpty(BigQueryHelpers.java:470)
>  at 
> org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO$Write.validate(BigQueryIO.java:1564)
>  at 
> org.apache.beam.sdk.Pipeline$ValidateVisitor.enterCompositeTransform(Pipeline.java:641)
>  at 
> org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:645)
>  at 
> org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:649)
>  at 
> org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:649)
>  at 
> org.apache.beam.sdk.runners.TransformHierarchy$Node.access$600(TransformHierarchy.java:311)
>  at 
> org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:245)
>  at org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:458)
>  at org.apache.beam.sdk.Pipeline.validate(Pipeline.java:577)
>  at org.apache.beam.sdk.Pipeline.run(Pipeline.java:312)
>  at org.apache.beam.sdk.Pipeline.run(Pipeline.java:299){code}



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to