Fix spotless formatting violations in streaming monitor

Author: durgaprasadml

runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TestDataflowRunner.java

@@ -392,7 +392,8 @@ private static class CancelOnError implements Callable<Void> {
     private final DataflowPipelineJob job;
     private final ErrorMonitorMessagesHandler messageHandler;
     private final TestDataflowRunner runner;
-    private final java.util.concurrent.atomic.AtomicReference<Optional<Boolean>> assertionsPassedRef;
+    private final java.util.concurrent.atomic.AtomicReference<Optional<Boolean>>
+        assertionsPassedRef;
 
     public CancelOnError(
         DataflowPipelineJob job,
@@ -418,7 +419,8 @@ public Void call() throws Exception {
             return null;
           }
 
-          // Check if we should initiate cancellation based on metrics (only if assertion state is not yet known)
+          // Check if we should initiate cancellation based on metrics (only if assertion state is
+          // not yet known)
           if (!assertionsPassedRef.get().isPresent() && !cancellationPending) {
             if (runner.expectedNumberOfAssertions > 0 && steps % checkMetricsIntervalSteps == 0) {
               try {
@@ -437,15 +439,13 @@ public Void call() throws Exception {
                   }
                 }
               } catch (Exception e) {
-                LOG.warn(
-                    "Transient error polling metrics for job {}",
-                    job.getJobId(),
-                    e);
+                LOG.warn("Transient error polling metrics for job {}", job.getJobId(), e);
               }
             }
           }
 
-          // Check if we should initiate cancellation based on error logs (only if not already cancellationPending)
+          // Check if we should initiate cancellation based on error logs (only if not already
+          // cancellationPending)
           if (!cancellationPending) {
             long runningTimeMillis = steps * 3000L;
             if (messageHandler.hasSeenError()
@@ -471,10 +471,7 @@ public Void call() throws Exception {
           }
 
         } catch (Exception e) {
-          LOG.warn(
-              "Exception in streaming job monitor loop for job {}",
-              job.getJobId(),
-              e);
+          LOG.warn("Exception in streaming job monitor loop for job {}", job.getJobId(), e);
         }
 
         Thread.sleep(3000L);

runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/TestDataflowRunnerTest.java

@@ -212,8 +212,7 @@ public void testBatchPipelineFailsIfException() throws Exception {
     when(mockClient.getJobMetrics(anyString()))
         .thenReturn(generateMockMetricResponse(false /* success */, true /* tentative */));
     TestDataflowRunner runner = TestDataflowRunner.fromOptionsAndClient(options, mockClient);
-    AssertionError expected =
-        assertThrows(AssertionError.class, () -> runner.run(p, mockRunner));
+    AssertionError expected = assertThrows(AssertionError.class, () -> runner.run(p, mockRunner));
     assertThat(expected.getMessage(), containsString("FooException"));
     verify(mockJob, never()).cancel();
   }