[incubator-hop] branch master updated: HOP-3182 : Beam BQ output Truncating table is not working

[hansva]

This is an automated email from the ASF dual-hosted git repository.

hansva pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-hop.git


The following commit(s) were added to refs/heads/master by this push:
     new 76efed2  HOP-3182 : Beam BQ output Truncating table is not working
     new 82535e0  Merge pull request #1066 from mattcasters/master
76efed2 is described below

commit 76efed2dd7a066cb918141f53d2b6b0c8e5bd831
Author: Matt Casters <mattcast...@gmail.com>
AuthorDate: Fri Sep 17 09:12:13 2021 +0200

    HOP-3182 : Beam BQ output Truncating table is not working
---
 .../org/apache/hop/beam/core/transform/BeamBQOutputTransform.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/plugins/engines/beam/src/main/java/org/apache/hop/beam/core/transform/BeamBQOutputTransform.java
 
b/plugins/engines/beam/src/main/java/org/apache/hop/beam/core/transform/BeamBQOutputTransform.java
index c8462ce..09260ed 100644
--- 
a/plugins/engines/beam/src/main/java/org/apache/hop/beam/core/transform/BeamBQOutputTransform.java
+++ 
b/plugins/engines/beam/src/main/java/org/apache/hop/beam/core/transform/BeamBQOutputTransform.java
@@ -6,7 +6,7 @@
  * (the "License"); you may not use this file except in compliance with
  * the License.  You may obtain a copy of the License at
  *
- *      http://www.apache.org/licenses/LICENSE-2.0
+ *       http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
@@ -150,7 +150,7 @@ public class BeamBQOutputTransform extends 
PTransform<PCollection<HopRow>, PDone
 
       BigQueryIO.Write.WriteDisposition writeDisposition;
       if (truncateTable) {
-        writeDisposition = BigQueryIO.Write.WriteDisposition.WRITE_APPEND;
+        writeDisposition = BigQueryIO.Write.WriteDisposition.WRITE_TRUNCATE;
       } else {
         if (failIfNotEmpty) {
           writeDisposition = BigQueryIO.Write.WriteDisposition.WRITE_EMPTY;