From 0605e8153422e8926357b8392c4c2f49403fe1dc Mon Sep 17 00:00:00 2001 From: Jin Seop Kim Date: Mon, 13 Apr 2026 14:25:11 -0400 Subject: [PATCH] test(bigquery): Fix flaky ITBigQueryTest#testOpenTelemetryTracingQuery b/467063732 --- .../com/google/cloud/bigquery/it/ITBigQueryTest.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it/ITBigQueryTest.java b/java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it/ITBigQueryTest.java index 25b90dc942ee..da26a52e63e7 100644 --- a/java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it/ITBigQueryTest.java +++ b/java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it/ITBigQueryTest.java @@ -7889,7 +7889,14 @@ public void testOpenTelemetryTracingQuery() throws InterruptedException { bigquery.getOptions().setDefaultJobCreationMode(JobCreationMode.JOB_CREATION_OPTIONAL); TableResult tableResult = executeSimpleQuery(bigquery); assertNotNull(tableResult.getQueryId()); - assertNull(tableResult.getJobId()); + // Safely handle the fallback where BigQuery decides to create a job anyway + if (tableResult.getJobCreationReason() != null) { + assertNotNull(tableResult.getJobId()); + assertEquals(tableResult.getQueryId(), tableResult.getJobId().getJob()); + assertEquals(JobCreationReason.Code.OTHER, tableResult.getJobCreationReason().getCode()); + } else { + assertNull(tableResult.getJobId()); + } assertNotNull(OTEL_ATTRIBUTES.get("com.google.cloud.bigquery.BigQuery.queryRpc")); assertNotNull(