Luat Nguyen created BEAM-6298:
---------------------------------
Summary: 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
Assignee: Xu Mingmin
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
(v7.6.3#76005)
