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(); } }