Repository: spark Updated Branches: refs/heads/branch-2.0 8e71b19f3 -> 28c015133
[SPARK-21991][LAUNCHER][FOLLOWUP] Fix java lint ## What changes were proposed in this pull request? Fix java lint ## How was this patch tested? Run `./dev/lint-java` Author: Andrew Ash <[email protected]> Closes #19574 from ash211/aash/fix-java-lint. (cherry picked from commit 5433be44caecaeef45ed1fdae10b223c698a9d14) Signed-off-by: Marcelo Vanzin <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/28c01513 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/28c01513 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/28c01513 Branch: refs/heads/branch-2.0 Commit: 28c015133c9e05522fefe8c048d3aed5d95461b6 Parents: 8e71b19 Author: Andrew Ash <[email protected]> Authored: Wed Oct 25 14:41:02 2017 -0700 Committer: Marcelo Vanzin <[email protected]> Committed: Wed Oct 25 14:41:41 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/spark/launcher/LauncherServer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/28c01513/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java ---------------------------------------------------------------------- diff --git a/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java b/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java index 970819f..4057d3f 100644 --- a/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java +++ b/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java @@ -240,7 +240,7 @@ class LauncherServer implements Closeable { synchronized (clients) { clients.add(clientConnection); } - + long timeoutMs = getConnectionTimeout(); // 0 is used for testing to avoid issues with clock resolution / thread scheduling, // and force an immediate timeout. @@ -249,7 +249,7 @@ class LauncherServer implements Closeable { } else { timeout.run(); } - + clientThread.start(); } } catch (IOException ioe) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
