Fix formatting issue

Author: priyanshu-ctds

tests/src/test/java/com/datastax/oss/pulsar/functions/transforms/tests/AbstractDockerTest.java

@@ -622,7 +622,9 @@ private void waitForFunctionRunning(String functionName) throws InterruptedExcep
             FunctionStatus status =
                 admin.functions().getFunctionStatus("public", "default", functionName);
 
-            status.getInstances().stream()
+            status
+                .getInstances()
+                .stream()
                 .filter(f -> !StringUtils.isEmpty(f.getStatus().getError()))
                 .findFirst()
                 .ifPresent(
@@ -650,7 +652,10 @@ private void waitForFunctionRunning(String functionName) throws InterruptedExcep
             future.completeExceptionally(e);
             scheduler.shutdown();
           }
-        }, 0, 2, TimeUnit.SECONDS);
+        },
+        0,
+        2,
+        TimeUnit.SECONDS);
 
     try {
       future.get();

tests/src/test/java/com/datastax/oss/pulsar/functions/transforms/tests/PulsarContainer.java

@@ -55,7 +55,8 @@ public void start() {
                     .withStrategy(Wait.defaultWaitStrategy())
                     .withStrategy(Wait.forLogMessage(".*Created namespace public/default.*", 1))
                     .withStrategy(Wait.forLogMessage(".*Function worker service started.*", 1))
-                    .withStrategy(Wait.forLogMessage(".*FunctionMetaDataManager done becoming leader.*", 1)))
+                    .withStrategy(
+                        Wait.forLogMessage(".*FunctionMetaDataManager done becoming leader.*", 1)))
             .withLogConsumer(
                 (f) -> {
                   String text = f.getUtf8String().trim();