You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sj...@apache.org on 2021/11/12 23:06:58 UTC
[flink] branch master updated: [hotfix][runtime] fix formatting in
MiniClusterResource
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 <sj...@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)