diff --git a/src/main/java/io/cdap/plugin/gcp/bigquery/sqlengine/BigQuerySQLEngine.java b/src/main/java/io/cdap/plugin/gcp/bigquery/sqlengine/BigQuerySQLEngine.java index 5db2550d27..46f9d16eb9 100644 --- a/src/main/java/io/cdap/plugin/gcp/bigquery/sqlengine/BigQuerySQLEngine.java +++ b/src/main/java/io/cdap/plugin/gcp/bigquery/sqlengine/BigQuerySQLEngine.java @@ -598,8 +598,9 @@ protected void deleteTable(String stageName, BigQuerySQLDataset bqDataset) throw String tableName = bqDataset.getBigQueryTable(); TableId tableId = TableId.of(datasetProject, dataset, tableName); - if (!bigQuery.delete(tableId)) { - LOG.error("Unable to delete BigQuery table '{}' for stage '{}'", tableName, stageName); + // Delete this table if found + if (bigQuery.getTable(tableId) != null) { + bigQuery.delete(tableId); } }