Skip to content

Commit 3024faa

Browse files
committed
test(bigquery): use queryWithTimeout on TABLE_ID_LARGE to guarantee pagination and avoid flaky sleep loop
b/467064659
1 parent 07f026f commit 3024faa

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

  • java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it

java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it/ITBigQueryTest.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -4831,30 +4831,30 @@ void testLocationFastSQLQueryWithJobId() throws InterruptedException {
48314831

48324832
/* TODO(prasmish): replicate the entire test case for executeSelect */
48334833
@Test
4834-
void testFastSQLQueryMultiPage() throws InterruptedException {
4834+
void testFastSQLQueryMultiPage() throws Exception {
48354835
String query =
48364836
"SELECT date, county, state_name, county_fips_code, confirmed_cases, deaths FROM "
48374837
+ TABLE_ID_LARGE.getTable();
48384838
QueryJobConfiguration config =
48394839
QueryJobConfiguration.newBuilder(query).setDefaultDataset(DatasetId.of(DATASET)).build();
4840-
TableResult result = bigquery.query(config);
4840+
TableResult result = (TableResult) bigquery.queryWithTimeout(config, null, 60000L);
48414841
assertNotNull(result.getJobId());
48424842
assertEquals(LARGE_TABLE_SCHEMA, result.getSchema());
48434843
assertEquals(313348, result.getTotalRows());
48444844
assertNotNull(result.getNextPage());
48454845
assertNotNull(result.getNextPageToken());
48464846
assertTrue(result.hasNextPage());
48474847

4848-
TableResult result1 = bigquery.query(config);
4848+
TableResult result1 = (TableResult) bigquery.queryWithTimeout(config, null, 60000L);
48494849
assertNotNull(result1.getJobId());
48504850
assertEquals(LARGE_TABLE_SCHEMA, result.getSchema());
48514851
assertEquals(313348, result.getTotalRows());
48524852
assertNotNull(result1.getNextPage());
48534853
assertNotNull(result1.getNextPageToken());
48544854
assertTrue(result1.hasNextPage());
48554855

4856-
config.toBuilder().setQuery(query).build();
4857-
TableResult result2 = bigquery.query(config);
4856+
config = config.toBuilder().setQuery(query).build();
4857+
TableResult result2 = (TableResult) bigquery.queryWithTimeout(config, null, 60000L);
48584858
assertNotNull(result2.getJobId());
48594859
assertEquals(LARGE_TABLE_SCHEMA, result2.getSchema());
48604860
assertEquals(313348, result2.getTotalRows());

0 commit comments

Comments
 (0)