You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by vt...@apache.org on 2025/12/01 12:33:42 UTC
(beam) branch fix-java-gcp-direct created (now 1cec86f4f05)
This is an automated email from the ASF dual-hosted git repository.
vterentev pushed a change to branch fix-java-gcp-direct
in repository https://gitbox.apache.org/repos/asf/beam.git
at 1cec86f4f05 Set query temp project and dataset for tests
This branch includes the following new commits:
new 1cec86f4f05 Set query temp project and dataset for tests
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(beam) 01/01: Set query temp project and dataset for tests
Posted by vt...@apache.org.
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 <vi...@akvelon.com>
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);
}