[flink] branch release-1.14 updated: [hotfix] Fix spotless issues in MiniClusterResource

[dwysakowicz]

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

dwysakowicz pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
     new ee5cb12  [hotfix] Fix spotless issues in MiniClusterResource
ee5cb12 is described below

commit ee5cb12537e5a4e34428c776a03508e56fd92f49
Author: Dawid Wysakowicz <dwysakow...@apache.org>
AuthorDate: Sat Nov 13 08:30:13 2021 +0100

    [hotfix] Fix spotless issues in MiniClusterResource
---
 .../org/apache/flink/runtime/testutils/MiniClusterResource.java  | 6 ++----
 .../org/apache/flink/streaming/util/TestStreamEnvironment.java   | 9 ++-------
 2 files changed, 4 insertions(+), 11 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)
diff --git 
a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java
 
b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java
index be095f8..0f8e714 100644
--- 
a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java
+++ 
b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java
@@ -118,14 +118,9 @@ public class TestStreamEnvironment extends 
StreamExecutionEnvironment {
             if 
(isConfigurationSupportedByChangelog(miniCluster.getConfiguration())) {
                 conf.set(CheckpointingOptions.ENABLE_STATE_CHANGE_LOG, true);
             }
-        } else if (STATE_CHANGE_LOG_CONFIG.equalsIgnoreCase(
-                STATE_CHANGE_LOG_CONFIG_RAND)) {
+        } else if 
(STATE_CHANGE_LOG_CONFIG.equalsIgnoreCase(STATE_CHANGE_LOG_CONFIG_RAND)) {
             if 
(isConfigurationSupportedByChangelog(miniCluster.getConfiguration())) {
-                randomize(
-                        conf,
-                        CheckpointingOptions.ENABLE_STATE_CHANGE_LOG,
-                        true,
-                        false);
+                randomize(conf, CheckpointingOptions.ENABLE_STATE_CHANGE_LOG, 
true, false);
             }
         }
     }