diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryStorageWriteApiSchemaTransformProvider.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryStorageWriteApiSchemaTransformProvider.java index 22e8abca35bc..3391c7ae51b5 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryStorageWriteApiSchemaTransformProvider.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryStorageWriteApiSchemaTransformProvider.java @@ -316,7 +316,8 @@ BigQueryIO.Write createStorageWriteApiTransform() { .to(configuration.getTable()) .withMethod(writeMethod) .useBeamSchema() - .withFormatFunction(BigQueryUtils.toTableRow()); + .withFormatFunction(BigQueryUtils.toTableRow()) + .withWriteDisposition(WriteDisposition.WRITE_APPEND); if (!Strings.isNullOrEmpty(configuration.getCreateDisposition())) { CreateDisposition createDisposition =