[hotfix][runtime] fix formatting in MiniClusterResource

akalash · Nov 12, 2021 · 1529b78 · 1529b78
1 parent 3262d9b
commit 1529b78
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java
@@ -109,8 +109,7 @@ public void cancelAllJobs() {
                                             .toMilliseconds()));
 
             final List<CompletableFuture<Acknowledge>> jobCancellationFutures =
-                    miniCluster
-                            .listJobs()
+                    miniCluster.listJobs()
                             .get(
                                     jobCancellationDeadline.timeLeft().toMillis(),
                                     TimeUnit.MILLISECONDS)
@@ -125,8 +124,7 @@ public void cancelAllJobs() {
             CommonTestUtils.waitUntilCondition(
                     () -> {
                         final long unfinishedJobs =
-                                miniCluster
-                                        .listJobs()
+                                miniCluster.listJobs()
                                         .get(
                                                 jobCancellationDeadline.timeLeft().toMillis(),
                                                 TimeUnit.MILLISECONDS)