Skip to content

Commit 81b66e4

Browse files
committed
Code review feedback.
1 parent a7533e3 commit 81b66e4

File tree

3 files changed

+5
-8
lines changed

3 files changed

+5
-8
lines changed

core/src/main/scala/org/apache/spark/deploy/worker/DriverRunner.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,6 @@ import org.apache.spark.deploy.master.DriverState
3333
import org.apache.spark.deploy.master.DriverState.DriverState
3434
import org.apache.spark.util.{Clock, SystemClock}
3535

36-
import scala.collection.mutable
37-
3836
/**
3937
* Manages the execution of one driver, including automatically restarting the driver on failure.
4038
* This is currently only used in standalone cluster deploy mode.
@@ -178,7 +176,7 @@ private[deploy] class DriverRunner(
178176
}
179177

180178
def runCommandWithRetry(
181-
command: ProcessBuilderLike, initialize: Process => Unit, supervise: Boolean) {
179+
command: ProcessBuilderLike, initialize: Process => Unit, supervise: Boolean): Unit = {
182180
// Time to wait between submission retries.
183181
var waitSeconds = 1
184182
// A run of this many seconds resets the exponential back-off.

core/src/main/scala/org/apache/spark/metrics/MetricsSystem.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,10 @@ package org.apache.spark.metrics
2020
import java.util.Properties
2121
import java.util.concurrent.TimeUnit
2222

23-
import org.eclipse.jetty.servlet.ServletContextHandler
24-
2523
import scala.collection.mutable
2624

2725
import com.codahale.metrics.{Metric, MetricFilter, MetricRegistry}
26+
import org.eclipse.jetty.servlet.ServletContextHandler
2827

2928
import org.apache.spark.{Logging, SecurityManager, SparkConf}
3029
import org.apache.spark.metrics.sink.{MetricsServlet, Sink}

scalastyle-config.xml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@
7575
<parameter name="regex"><![CDATA[^[a-z][A-Za-z]*$]]></parameter>
7676
</parameters>
7777
</check>
78-
<check level="error" class="org.scalastyle.scalariform.EqualsHashCodeChecker" enabled="false"></check>
78+
<check level="error" class="org.scalastyle.scalariform.EqualsHashCodeChecker" enabled="true"></check>
7979
<!-- <check level="error" class="org.scalastyle.scalariform.IllegalImportsChecker" enabled="true"> -->
8080
<!-- <parameters> -->
8181
<!-- <parameter name="illegalImports"><![CDATA[sun._,java.awt._]]></parameter> -->
@@ -137,9 +137,9 @@
137137
<!-- <parameter name="maxMethods"><![CDATA[30]]></parameter> -->
138138
<!-- </parameters> -->
139139
<!-- </check> -->
140-
<!-- <check level="error" class="org.scalastyle.scalariform.PublicMethodsHaveTypeChecker" enabled="true"></check> -->
140+
<check level="error" class="org.scalastyle.scalariform.PublicMethodsHaveTypeChecker" enabled="true"></check>
141141
<check level="error" class="org.scalastyle.file.NewLineAtEofChecker" enabled="true"></check>
142142
<check level="error" class="org.scalastyle.file.NoNewLineAtEofChecker" enabled="false"></check>
143-
<check level="error" class="org.apache.spark.scalastyle.NonASCIICharacterChecker" enabled="true"></check>
143+
<check level="error" class="org.scalastyle.scalariform.NonASCIICharacterChecker" enabled="true"></check>
144144
<check level="error" class="org.scalastyle.scalariform.SpaceAfterCommentStartChecker" enabled="true"></check>
145145
</scalastyle>

0 commit comments

Comments
 (0)