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);
     }

Reply via email to