From 86f4b91d9bf2916f48ba9fd12aacacecc8e805e5 Mon Sep 17 00:00:00 2001 From: flakrim Date: Wed, 17 Feb 2021 09:07:01 +0100 Subject: [PATCH] PLUGIN-557: BigQuerySink fix for upsert operation in existing table but in different project --- .../java/io/cdap/plugin/gcp/bigquery/sink/BigQuerySink.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/io/cdap/plugin/gcp/bigquery/sink/BigQuerySink.java b/src/main/java/io/cdap/plugin/gcp/bigquery/sink/BigQuerySink.java index 5f62c9986..db6ea25f8 100644 --- a/src/main/java/io/cdap/plugin/gcp/bigquery/sink/BigQuerySink.java +++ b/src/main/java/io/cdap/plugin/gcp/bigquery/sink/BigQuerySink.java @@ -231,7 +231,7 @@ private void configureBigQuerySink() { */ private void configureTable(Schema schema) { AbstractBigQuerySinkConfig config = getConfig(); - Table table = BigQueryUtil.getBigQueryTable(config.getProject(), config.getDataset(), + Table table = BigQueryUtil.getBigQueryTable(config.getDatasetProject(), config.getDataset(), config.getTable(), config.getServiceAccount(), config.isServiceAccountFilePath()); @@ -253,7 +253,7 @@ private void validateConfiguredSchema(Schema schema, FailureCollector collector) } String tableName = config.getTable(); - Table table = BigQueryUtil.getBigQueryTable(config.getProject(), config.getDataset(), tableName, + Table table = BigQueryUtil.getBigQueryTable(config.getDatasetProject(), config.getDataset(), tableName, config.getServiceAccount(), config.isServiceAccountFilePath(), collector);