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

kkloudas pushed a commit to branch executor-impl
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 7528d5c8082b75cad49d34189c55bfa9397fe954
Author: Kostas Kloudas <kklou...@gmail.com>
AuthorDate: Fri Nov 15 15:38:31 2019 +0100

    [hotfix] code style fix
---
 .../src/main/java/org/apache/flink/client/RemoteExecutor.java         | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/flink-clients/src/main/java/org/apache/flink/client/RemoteExecutor.java 
b/flink-clients/src/main/java/org/apache/flink/client/RemoteExecutor.java
index c9a041d..51fb99f 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/RemoteExecutor.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/RemoteExecutor.java
@@ -124,9 +124,7 @@ public class RemoteExecutor extends PlanExecutor {
                checkNotNull(jobGraph);
                checkNotNull(classLoader);
 
-               try (ClusterClient<?> client = new RestClusterClient<>(
-                               clientConfiguration,
-                               "RemoteExecutor")) {
+               try (ClusterClient<?> client = new 
RestClusterClient<>(clientConfiguration, "RemoteExecutor")) {
                        return ClientUtils.submitJobAndWaitForResult(client, 
jobGraph, classLoader).getJobExecutionResult();
                }
        }

Reply via email to