Fix style

nemccarthy · May 15, 2015 · 1af0b0e · 1af0b0e
1 parent 074c00b
commit 1af0b0e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/...rnal/flume/src/main/scala/org/apache/spark/streaming/flume/FlumePollingInputDStream.scala b/...rnal/flume/src/main/scala/org/apache/spark/streaming/flume/FlumePollingInputDStream.scala
@@ -53,7 +53,9 @@ private[streaming] class FlumePollingInputDStream[T: ClassTag](
     storageLevel: StorageLevel
   ) extends ReceiverInputDStream[SparkFlumeEvent](_ssc) {
 
-  protected[streaming] override val customScopeName: Option[String] = Some(s"flume polling stream [$id]")
+  protected[streaming] override val customScopeName: Option[String] = {
+    Some(s"flume polling stream [$id]")
+  }
 
   override def getReceiver(): Receiver[SparkFlumeEvent] = {
     new FlumePollingReceiver(addresses, maxBatchSize, parallelism, storageLevel)

diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/DirectKafkaInputDStream.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/DirectKafkaInputDStream.scala
@@ -65,7 +65,9 @@ class DirectKafkaInputDStream[
   val maxRetries = context.sparkContext.getConf.getInt(
     "spark.streaming.kafka.maxRetries", 1)
 
-  protected[streaming] override val customScopeName: Option[String] = Some(s"kafka direct stream [$id]")
+  protected[streaming] override val customScopeName: Option[String] = {
+    Some(s"kafka direct stream [$id]")
+  }
 
   protected[streaming] override val checkpointData =
     new DirectKafkaInputDStreamCheckpointData