fix lint errors (#34092)

Co-authored-by: Naireen <[email protected]>

Author: Naireen

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiSinkRowUpdateIT.java

@@ -24,10 +24,9 @@
 import com.google.api.services.bigquery.model.TableFieldSchema;
 import com.google.api.services.bigquery.model.TableRow;
 import com.google.api.services.bigquery.model.TableSchema;
+import com.google.cloud.bigquery.storage.v1.Exceptions;
 import java.io.IOException;
 import java.util.List;
-
-import com.google.cloud.bigquery.storage.v1.Exceptions;
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.PipelineResult;
 import org.apache.beam.sdk.extensions.gcp.options.GcpOptions;
@@ -212,12 +211,12 @@ private void runPipelineAndWait(Pipeline p) {
       while (root != null && root.getCause() != null) {
         root = root.getCause();
       }
-      // Tolerate a StreamWriterClosedException, which sometimes happens after all writes have been flushed.
+      // Tolerate a StreamWriterClosedException, which sometimes happens after all writes have been
+      // flushed.
       if (root instanceof Exceptions.StreamWriterClosedException) {
         return;
       }
       throw e;
     }
   }
-
 }

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiSinkSchemaUpdateIT.java

@@ -228,7 +228,8 @@ public void setup() {
     public void processElement(ProcessContext c, @StateId(ROW_COUNTER) ValueState<Integer> counter)
         throws Exception {
       int current = firstNonNull(counter.read(), 0);
-      // We update schema early on to leave a healthy amount of time for the StreamWriter to recognize it,
+      // We update schema early on to leave a healthy amount of time for the StreamWriter to
+      // recognize it,
       // ensuring that subsequent writers are created with the updated schema.
       if (current == SCHEMA_UPDATE_TRIGGER) {
         for (Map.Entry<String, String> entry : newSchemas.entrySet()) {
@@ -246,8 +247,10 @@ public void processElement(ProcessContext c, @StateId(ROW_COUNTER) ValueState<In
         while (System.currentTimeMillis() - startTime < timeoutMillis) {
           schemaPropagated = true;
           for (Map.Entry<String, String> entry : newSchemas.entrySet()) {
-            TableSchema currentSchema = bqClient.getTableResource(projectId, datasetId, entry.getKey()).getSchema();
-            TableSchema expectedSchema = BigQueryHelpers.fromJsonString(entry.getValue(), TableSchema.class);
+            TableSchema currentSchema =
+                bqClient.getTableResource(projectId, datasetId, entry.getKey()).getSchema();
+            TableSchema expectedSchema =
+                BigQueryHelpers.fromJsonString(entry.getValue(), TableSchema.class);
             if (currentSchema.getFields().size() != expectedSchema.getFields().size()) {
               schemaPropagated = false;
               break;
@@ -261,7 +264,9 @@ public void processElement(ProcessContext c, @StateId(ROW_COUNTER) ValueState<In
         if (!schemaPropagated) {
           LOG.warn("Schema update did not propagate fully within the timeout.");
         } else {
-          LOG.info("Schema update propagated fully within the timeout - {}.", System.currentTimeMillis() - startTime);
+          LOG.info(
+              "Schema update propagated fully within the timeout - {}.",
+              System.currentTimeMillis() - startTime);
           // wait for streams to recognize the new schema
           Thread.sleep(STREAM_RECOGNITION_DELAY_MS);
         }
@@ -409,14 +414,19 @@ private void runStreamingPipelineWithSchemaChange(
     // recognize the new schema. Apply on relevant tests.
     boolean waitLonger = changeTableSchema && (useAutoSchemaUpdate || !useInputSchema);
     if (method == Write.Method.STORAGE_WRITE_API) {
-      write = write.withTriggeringFrequency(Duration.standardSeconds(waitLonger ? LONG_WAIT_SECONDS : 1));
+      write =
+          write.withTriggeringFrequency(
+              Duration.standardSeconds(waitLonger ? LONG_WAIT_SECONDS : 1));
     }
 
     // set up and build pipeline
     Instant start = new Instant(0);
-    Duration interval = waitLonger ? Duration.standardSeconds(LONG_WAIT_SECONDS) : Duration.millis(1);
+    Duration interval =
+        waitLonger ? Duration.standardSeconds(LONG_WAIT_SECONDS) : Duration.millis(1);
     Duration stop =
-        waitLonger ? Duration.standardSeconds((TOTAL_N - 1) * LONG_WAIT_SECONDS) : Duration.millis(TOTAL_N - 1);
+        waitLonger
+            ? Duration.standardSeconds((TOTAL_N - 1) * LONG_WAIT_SECONDS)
+            : Duration.millis(TOTAL_N - 1);
     Function<Instant, Long> getIdFromInstant =
         waitLonger
             ? (Function<Instant, Long> & Serializable)
@@ -666,17 +676,21 @@ public void runDynamicDestinationsWithAutoSchemaUpdate(boolean useAtLeastOnce) t
       write =
           write
               .withMethod(Write.Method.STORAGE_WRITE_API)
-              .withTriggeringFrequency(Duration.standardSeconds(changeTableSchema ? LONG_WAIT_SECONDS : 1));
+              .withTriggeringFrequency(
+                  Duration.standardSeconds(changeTableSchema ? LONG_WAIT_SECONDS : 1));
     }
 
     int numRows = TOTAL_N;
     // set up and build pipeline
     Instant start = new Instant(0);
     // We give a healthy waiting period between each element to give Storage API streams a chance to
     // recognize the new schema. Apply on relevant tests.
-    Duration interval = changeTableSchema ? Duration.standardSeconds(LONG_WAIT_SECONDS) : Duration.millis(1);
+    Duration interval =
+        changeTableSchema ? Duration.standardSeconds(LONG_WAIT_SECONDS) : Duration.millis(1);
     Duration stop =
-        changeTableSchema ? Duration.standardSeconds((numRows - 1) * LONG_WAIT_SECONDS) : Duration.millis(numRows - 1);
+        changeTableSchema
+            ? Duration.standardSeconds((numRows - 1) * LONG_WAIT_SECONDS)
+            : Duration.millis(numRows - 1);
     Function<Instant, Long> getIdFromInstant =
         changeTableSchema
             ? (Function<Instant, Long> & Serializable)