Description
On DataFlow:
Error message from worker: java.lang.RuntimeException: org.apache.beam.sdk.util.UserCodeException: java.lang.NoClassDefFoundError: com/google/cloud/bigquery/storage/v1beta2/CreateWriteStreamRequest
The API changed from v1beta1 to v1beta2 (yeah)