fix imports ordering

Author: whowes

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

@@ -16,12 +16,9 @@
 
 package com.google.cloud.bigquery.storage.v1beta1.it;
 
-import static org.awaitility.Awaitility.await;
-import com.google.api.gax.rpc.NotFoundException;
-import java.util.Objects;
-
 import static com.google.common.truth.Truth.assertThat;
 import static com.google.common.truth.Truth.assertWithMessage;
+import static org.awaitility.Awaitility.await;
 import static org.junit.jupiter.api.Assertions.assertArrayEquals;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -30,6 +27,7 @@
 import static org.junit.jupiter.api.Assertions.fail;
 
 import com.google.api.gax.core.FixedCredentialsProvider;
+import com.google.api.gax.rpc.NotFoundException;
 import com.google.api.gax.rpc.ServerStream;
 import com.google.api.gax.rpc.UnauthenticatedException;
 import com.google.auth.oauth2.ServiceAccountCredentials;
@@ -83,6 +81,7 @@
 import java.util.Collections;
 import java.util.Iterator;
 import java.util.List;
+import java.util.Objects;
 import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 import java.util.logging.Logger;
@@ -1237,8 +1236,9 @@ private void ProcessRowsAtSnapshot(
     final CreateReadSessionRequest request = createSessionRequestBuilder.build();
     ReadSession session =
         await()
-            .atMost(Duration.ofSeconds(30))
+            .atMost(Duration.ofSeconds(10))
             .pollInterval(Duration.ofSeconds(1))
+            // retry if the newly-created table has not yet fully propagated
             .ignoreException(NotFoundException.class)
             .until(() -> client.createReadSession(request), Objects::nonNull);
     assertEquals(

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

@@ -16,12 +16,9 @@
 
 package com.google.cloud.bigquery.storage.v1beta2.it;
 
-import static org.awaitility.Awaitility.await;
-import com.google.api.gax.rpc.NotFoundException;
-import java.util.Objects;
-
 import static com.google.common.truth.Truth.assertThat;
 import static com.google.common.truth.Truth.assertWithMessage;
+import static org.awaitility.Awaitility.await;
 import static org.junit.jupiter.api.Assertions.assertArrayEquals;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -30,6 +27,7 @@
 import static org.junit.jupiter.api.Assertions.fail;
 
 import com.google.api.gax.core.FixedCredentialsProvider;
+import com.google.api.gax.rpc.NotFoundException;
 import com.google.api.gax.rpc.ServerStream;
 import com.google.api.gax.rpc.UnauthenticatedException;
 import com.google.auth.oauth2.ServiceAccountCredentials;
@@ -80,6 +78,7 @@
 import java.util.Collections;
 import java.util.Iterator;
 import java.util.List;
+import java.util.Objects;
 import java.util.UUID;
 import java.util.logging.Logger;
 import org.apache.avro.Conversions;
@@ -1218,8 +1217,9 @@ private void ProcessRowsAtSnapshot(
     final CreateReadSessionRequest request = createSessionRequestBuilder.build();
     ReadSession session =
         await()
-            .atMost(Duration.ofSeconds(30))
+            .atMost(Duration.ofSeconds(10))
             .pollInterval(Duration.ofSeconds(1))
+            // retry if the newly-created table has not yet fully propagated
             .ignoreException(NotFoundException.class)
             .until(() -> client.createReadSession(request), Objects::nonNull);
     assertEquals(