David Artiga

Results 6 comments of David Artiga

> I am not able to replicate this exception with the code you provided. Are you getting any error or just green test? I am able to replicate the issue...

That sounds like your `tempLocation` is not valid. Let me see if I can reproduce your error and update the code.

In order to fix your issue you might need to provide a valid GS bucket (where you should have permissions for writing) when setting `tempLocation` option. So either you replace...

Beam ITs follow the same approach https://github.com/apache/beam/blob/04f49848d4b037a5935036927e54c8eb8ed8c361/sdks/java/io/google-cloud-platform/build.gradle#L186

That's because [`UpdateSchemaDestination`](https://github.com/apache/beam/blob/04f49848d4b037a5935036927e54c8eb8ed8c361/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/UpdateSchemaDestination.java) is [used in `BatchLoads`](https://github.com/apache/beam/blob/04f49848d4b037a5935036927e54c8eb8ed8c361/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java#L476) only. It was [introduced in 2.40](https://github.com/apache/beam/pull/17365). As @johnjcasey mentioned, our custom `DynamicDestinations` expects `String` to be received, while `UpdateSchemaDestination` [assumes `TableDestination` instances always](https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/UpdateSchemaDestination.java#L119)....