You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2019/11/18 13:11:03 UTC
[flink] 07/19: [hotfix] code style fix
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 <kk...@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();
}
}