[flink] branch master updated: [hotfix][runtime] fix formatting in MiniClusterResource

[sjwiesman]

This is an automated email from the ASF dual-hosted git repository.

sjwiesman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 1529b78  [hotfix][runtime] fix formatting in MiniClusterResource
1529b78 is described below

commit 1529b78ddc4abc69b8fd3ca1cafef057aa53e3cb
Author: sjwiesman <sjwies...@gmail.com>
AuthorDate: Fri Nov 12 17:06:30 2021 -0600

    [hotfix][runtime] fix formatting in MiniClusterResource
---
 .../org/apache/flink/runtime/testutils/MiniClusterResource.java     | 6 ++----
 1 file changed, 2 insertions(+), 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
index c6799f3..06f0736 100644
--- 
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 class MiniClusterResource extends ExternalResource {
                                             .toMilliseconds()));
 
             final List<CompletableFuture<Acknowledge>> jobCancellationFutures =
-                    miniCluster
-                            .listJobs()
+                    miniCluster.listJobs()
                             .get(
                                     
jobCancellationDeadline.timeLeft().toMillis(),
                                     TimeUnit.MILLISECONDS)
@@ -125,8 +124,7 @@ public class MiniClusterResource extends ExternalResource {
             CommonTestUtils.waitUntilCondition(
                     () -> {
                         final long unfinishedJobs =
-                                miniCluster
-                                        .listJobs()
+                                miniCluster.listJobs()
                                         .get(
                                                 
jobCancellationDeadline.timeLeft().toMillis(),
                                                 TimeUnit.MILLISECONDS)