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 a58a91fa2cd1c2432f284c00787d540abc9f7a36 Author: Kostas Kloudas <[email protected]> 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(); } }
