fix scalastyle check

Author: nlu90

src/main/scala/org/apache/spark/sql/pulsar/JSONParser.scala

@@ -367,7 +367,7 @@ class JacksonRecordParser(schema: DataType, val options: JSONOptions) extends Lo
       case e @ (_: RuntimeException | _: JsonProcessingException | _: MalformedInputException) =>
         // JSON parser currently doesn't support partial results for corrupted records.
         // For such records, all fields other than the meta fields are set to `null`.
-        throw BadRecordException(() => recordLiteral(record), () =>Array.empty[InternalRow], e)
+        throw BadRecordException(() => recordLiteral(record), () => Array.empty[InternalRow], e)
       case e: CharConversionException if options.encoding.isEmpty =>
         val msg =
           """JSON parser cannot handle a character in its input.

src/main/scala/org/apache/spark/sql/pulsar/PulsarSinks.scala

@@ -15,11 +15,13 @@ package org.apache.spark.sql.pulsar
 
 import java.{util => ju}
 import java.util.concurrent.TimeUnit
+
 import scala.util.control.NonFatal
+
 import org.apache.pulsar.client.api.{Producer, PulsarClientException, Schema}
-import org.apache.spark.SparkEnv
+
 import org.apache.spark.internal.Logging
-import org.apache.spark.sql.{AnalysisException, DataFrame, SQLContext, SparkSession}
+import org.apache.spark.sql.{AnalysisException, DataFrame, SparkSession, SQLContext}
 import org.apache.spark.sql.catalyst.expressions
 import org.apache.spark.sql.catalyst.expressions.{Attribute, Literal}
 import org.apache.spark.sql.catalyst.types.DataTypeUtils