Skip to content

Commit 5125249

Browse files
committed
fix imports ordering
1 parent b5628d9 commit 5125249

2 files changed

Lines changed: 8 additions & 8 deletions

File tree

java-bigquerystorage/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,9 @@
1616

1717
package com.google.cloud.bigquery.storage.v1beta1.it;
1818

19-
import static org.awaitility.Awaitility.await;
20-
import com.google.api.gax.rpc.NotFoundException;
21-
import java.util.Objects;
22-
2319
import static com.google.common.truth.Truth.assertThat;
2420
import static com.google.common.truth.Truth.assertWithMessage;
21+
import static org.awaitility.Awaitility.await;
2522
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
2623
import static org.junit.jupiter.api.Assertions.assertEquals;
2724
import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -30,6 +27,7 @@
3027
import static org.junit.jupiter.api.Assertions.fail;
3128

3229
import com.google.api.gax.core.FixedCredentialsProvider;
30+
import com.google.api.gax.rpc.NotFoundException;
3331
import com.google.api.gax.rpc.ServerStream;
3432
import com.google.api.gax.rpc.UnauthenticatedException;
3533
import com.google.auth.oauth2.ServiceAccountCredentials;
@@ -83,6 +81,7 @@
8381
import java.util.Collections;
8482
import java.util.Iterator;
8583
import java.util.List;
84+
import java.util.Objects;
8685
import java.util.UUID;
8786
import java.util.concurrent.TimeUnit;
8887
import java.util.logging.Logger;
@@ -1239,6 +1238,7 @@ private void ProcessRowsAtSnapshot(
12391238
await()
12401239
.atMost(Duration.ofSeconds(30))
12411240
.pollInterval(Duration.ofSeconds(1))
1241+
// retry if the newly-created table has not yet fully propagated
12421242
.ignoreException(NotFoundException.class)
12431243
.until(() -> client.createReadSession(request), Objects::nonNull);
12441244
assertEquals(

java-bigquerystorage/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryStorageTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,9 @@
1616

1717
package com.google.cloud.bigquery.storage.v1beta2.it;
1818

19-
import static org.awaitility.Awaitility.await;
20-
import com.google.api.gax.rpc.NotFoundException;
21-
import java.util.Objects;
22-
2319
import static com.google.common.truth.Truth.assertThat;
2420
import static com.google.common.truth.Truth.assertWithMessage;
21+
import static org.awaitility.Awaitility.await;
2522
import static org.junit.jupiter.api.Assertions.assertArrayEquals;
2623
import static org.junit.jupiter.api.Assertions.assertEquals;
2724
import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -30,6 +27,7 @@
3027
import static org.junit.jupiter.api.Assertions.fail;
3128

3229
import com.google.api.gax.core.FixedCredentialsProvider;
30+
import com.google.api.gax.rpc.NotFoundException;
3331
import com.google.api.gax.rpc.ServerStream;
3432
import com.google.api.gax.rpc.UnauthenticatedException;
3533
import com.google.auth.oauth2.ServiceAccountCredentials;
@@ -80,6 +78,7 @@
8078
import java.util.Collections;
8179
import java.util.Iterator;
8280
import java.util.List;
81+
import java.util.Objects;
8382
import java.util.UUID;
8483
import java.util.logging.Logger;
8584
import org.apache.avro.Conversions;
@@ -1220,6 +1219,7 @@ private void ProcessRowsAtSnapshot(
12201219
await()
12211220
.atMost(Duration.ofSeconds(30))
12221221
.pollInterval(Duration.ofSeconds(1))
1222+
// retry if the newly-created table has not yet fully propagated
12231223
.ignoreException(NotFoundException.class)
12241224
.until(() -> client.createReadSession(request), Objects::nonNull);
12251225
assertEquals(

0 commit comments

Comments
 (0)