From f0ddf426c2ef55871dfa5a0aee6d4e8be3a0e254 Mon Sep 17 00:00:00 2001 From: Dan Sanduleac Date: Mon, 26 Mar 2018 15:07:24 +0100 Subject: [PATCH] Make AbstractLauncher#self() protected --- .../main/java/org/apache/spark/launcher/AbstractLauncher.java | 2 +- .../main/java/org/apache/spark/launcher/InProcessLauncher.java | 2 +- .../src/main/java/org/apache/spark/launcher/SparkLauncher.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/launcher/src/main/java/org/apache/spark/launcher/AbstractLauncher.java b/launcher/src/main/java/org/apache/spark/launcher/AbstractLauncher.java index 44e69fc45dffa..3524eb0afb51e 100644 --- a/launcher/src/main/java/org/apache/spark/launcher/AbstractLauncher.java +++ b/launcher/src/main/java/org/apache/spark/launcher/AbstractLauncher.java @@ -274,7 +274,7 @@ public T setVerbose(boolean verbose) { public abstract SparkAppHandle startApplication(SparkAppHandle.Listener... listeners) throws IOException; - abstract T self(); + protected abstract T self(); private static class ArgumentValidator extends SparkSubmitOptionParser { diff --git a/launcher/src/main/java/org/apache/spark/launcher/InProcessLauncher.java b/launcher/src/main/java/org/apache/spark/launcher/InProcessLauncher.java index 6d726b4a69a86..0f36c1aadb9a7 100644 --- a/launcher/src/main/java/org/apache/spark/launcher/InProcessLauncher.java +++ b/launcher/src/main/java/org/apache/spark/launcher/InProcessLauncher.java @@ -77,7 +77,7 @@ public SparkAppHandle startApplication(SparkAppHandle.Listener... listeners) thr } @Override - InProcessLauncher self() { + protected InProcessLauncher self() { return this; } diff --git a/launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java b/launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java index f86d40015bd22..8a952db5cfef4 100644 --- a/launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java +++ b/launcher/src/main/java/org/apache/spark/launcher/SparkLauncher.java @@ -453,7 +453,7 @@ private ProcessBuilder createBuilder() throws IOException { } @Override - SparkLauncher self() { + protected SparkLauncher self() { return this; }