Address the comments

Author: jerryshao

external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala

@@ -196,8 +196,8 @@ private class KafkaTestUtils extends Logging {
     props
   }
 
-    // A simplified version of scalatest eventually, rewritten here is to avoid adding extra test
-    // dependency
+  // A simplified version of scalatest eventually, rewritten here to avoid adding extra test
+  // dependency
   def eventually[T](timeout: Time, interval: Time)(func: => T): T = {
     def makeAttempt(): Either[Throwable, T] = {
       try {

external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaDirectKafkaStreamSuite.java

@@ -47,7 +47,6 @@ public class JavaDirectKafkaStreamSuite implements Serializable {
   public void setUp() {
     kafkaTestUtils = new KafkaTestUtils();
     kafkaTestUtils.setup();
-    System.clearProperty("spark.driver.port");
     SparkConf sparkConf = new SparkConf()
       .setMaster("local[4]").setAppName(this.getClass().getSimpleName());
     ssc = new JavaStreamingContext(sparkConf, Durations.milliseconds(200));
@@ -60,8 +59,6 @@ public void tearDown() {
       ssc = null;
     }
 
-    System.clearProperty("spark.driver.port");
-
     if (kafkaTestUtils != null) {
       kafkaTestUtils.teardown();
       kafkaTestUtils = null;

external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaRDDSuite.java

@@ -43,7 +43,6 @@ public class JavaKafkaRDDSuite implements Serializable {
   public void setUp() {
     kafkaTestUtils = new KafkaTestUtils();
     kafkaTestUtils.setup();
-    System.clearProperty("spark.driver.port");
     SparkConf sparkConf = new SparkConf()
       .setMaster("local[4]").setAppName(this.getClass().getSimpleName());
     sc = new JavaSparkContext(sparkConf);
@@ -55,7 +54,6 @@ public void tearDown() {
       sc.stop();
       sc = null;
     }
-    System.clearProperty("spark.driver.port");
 
     if (kafkaTestUtils != null) {
       kafkaTestUtils.teardown();

external/kafka/src/test/java/org/apache/spark/streaming/kafka/JavaKafkaStreamSuite.java

@@ -48,7 +48,6 @@ public class JavaKafkaStreamSuite implements Serializable {
   public void setUp() {
     kafkaTestUtils = new KafkaTestUtils();
     kafkaTestUtils.setup();
-    System.clearProperty("spark.driver.port");
     SparkConf sparkConf = new SparkConf()
       .setMaster("local[4]").setAppName(this.getClass().getSimpleName());
     ssc = new JavaStreamingContext(sparkConf, new Duration(500));
@@ -61,8 +60,6 @@ public void tearDown() {
       ssc = null;
     }
 
-    System.clearProperty("spark.driver.port");
-
     if (kafkaTestUtils != null) {
       kafkaTestUtils.teardown();
       kafkaTestUtils = null;