more scalastyle off/on

Author: gengliangwang

core/src/test/scala/org/apache/spark/scheduler/TaskSetManagerSuite.scala

@@ -85,8 +85,10 @@ object FakeRackUtil {
  * a list of "live" executors and their hostnames for isExecutorAlive and hasExecutorsAliveOnHost
  * to work, and these are required for locality in TaskSetManager.
  */
+// scalastyle:off
 class FakeTaskScheduler(sc: SparkContext, liveExecutors: (String, String)* /* execId, host */)
   extends TaskSchedulerImpl(sc)
+// scalastyle:on
 {
   val startedTasks = new ArrayBuffer[Long]
   val endedTasks = new mutable.HashMap[Long, TaskEndReason]

core/src/test/scala/org/apache/spark/shuffle/sort/BypassMergeSortShuffleWriterSuite.scala

@@ -140,7 +140,9 @@ class BypassMergeSortShuffleWriterSuite extends SparkFunSuite with BeforeAndAfte
       conf
     )
     writer.write(Iterator.empty)
+    // scalastyle:off
     writer.stop(/* success = */ true)
+    // scalastyle:on
     assert(writer.getPartitionLengths.sum === 0)
     assert(outputFile.exists())
     assert(outputFile.length() === 0)
@@ -164,7 +166,9 @@ class BypassMergeSortShuffleWriterSuite extends SparkFunSuite with BeforeAndAfte
       conf
     )
     writer.write(records)
+    // scalastyle:off
     writer.stop(/* success = */ true)
+    // scalastyle:on
     assert(temporaryFilesCreated.nonEmpty)
     assert(writer.getPartitionLengths.sum === outputFile.length())
     assert(writer.getPartitionLengths.count(_ == 0L) === 4) // should be 4 zero length files
@@ -206,8 +210,9 @@ class BypassMergeSortShuffleWriterSuite extends SparkFunSuite with BeforeAndAfte
     assert(temporaryFilesCreated.nonEmpty)
     // Only 3 temp shuffle files will be created
     assert(temporaryFilesCreated.count(_.exists()) === 3)
-
+    // scalastyle:off
     writer.stop(/* success = */ false)
+    // scalastyle:on
     assert(temporaryFilesCreated.count(_.exists()) === 0) // check that temporary files were deleted
   }
 
@@ -229,7 +234,9 @@ class BypassMergeSortShuffleWriterSuite extends SparkFunSuite with BeforeAndAfte
       }))
     }
     assert(temporaryFilesCreated.nonEmpty)
+    // scalastyle:off
     writer.stop(/* success = */ false)
+    // scalastyle:on
     assert(temporaryFilesCreated.count(_.exists()) === 0)
   }
 

sql/core/src/test/scala/org/apache/spark/sql/streaming/FileStreamSourceSuite.scala

@@ -1232,7 +1232,9 @@ class FileStreamSourceSuite extends FileStreamSourceTest {
       f2.setLastModified(f1.lastModified + 3600 * 1000 /* 1 hour later */)
 
       runTwoBatchesAndVerifyResults(src, latestFirst = true, firstBatch = "2", secondBatch = "1",
+        // scalastyle:off
         maxFileAge = Some("1m") /* 1 minute */)
+        // scalastyle:on
     }
   }
 

sql/hive/src/test/scala/org/apache/spark/sql/hive/PartitionedTablePerfStatsSuite.scala

@@ -241,7 +241,9 @@ class PartitionedTablePerfStatsSuite
   genericTest("file status cache respects size limit") { spec =>
     withSQLConf(
         SQLConf.HIVE_MANAGE_FILESOURCE_PARTITIONS.key -> "true",
+        //scalastyle:off
         SQLConf.HIVE_FILESOURCE_PARTITION_FILE_CACHE_SIZE.key -> "1" /* 1 byte */) {
+        //scalastyle:on
       withTable("test") {
         withTempDir { dir =>
           spec.setupTable("test", dir)