This class is a smell: https://github.com/mkuthan/stream-processing/blob/main/stream-processing-test/src/main/scala/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesFactory.scala Use another client for managing BigQuery integration tests instead of internal Beam API.