This is an automated email from the ASF dual-hosted git repository. vterentev pushed a commit to branch fix-java-gcp-direct in repository https://gitbox.apache.org/repos/asf/beam.git
commit 1cec86f4f0507b9d2cf458e1761c155eb85f55b4 Author: Vitaly Terentyev <[email protected]> AuthorDate: Mon Dec 1 16:33:28 2025 +0400 Set query temp project and dataset for tests --- .../apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadTest.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadTest.java index 9fd777b477b..862bae082ef 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadTest.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadTest.java @@ -734,7 +734,9 @@ public class BigQueryIODynamicReadTest { new FakeBigQueryServices() .withDatasetService(fakeDatasetService) .withJobService(fakeJobService) - .withStorageClient(fakeStorageClient)); + .withStorageClient(fakeStorageClient)) + .withQueryTempProject("project") + .withQueryTempDataset("dataset"); if (errorHandler != null) { t = t.withBadRecordErrorHandler(errorHandler); }
