From 2b0b1ce3876e2f55807156a98f75068280e03054 Mon Sep 17 00:00:00 2001 From: Reza Safi Date: Fri, 24 Aug 2018 15:08:44 -0400 Subject: [PATCH] Fix the scalastyle issue --- .../apache/spark/streaming/kafka010/PerPartitionConfig.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala b/external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala index 4dc4a1ced5b26..3c5d63876d4d3 100644 --- a/external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala +++ b/external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala @@ -44,7 +44,7 @@ private class DefaultPerPartitionConfig(conf: SparkConf) extends PerPartitionConfig { val maxRate = conf.getLong("spark.streaming.kafka.maxRatePerPartition", 0) val minRate = conf.getLong("spark.streaming.kafka.minRatePerPartition", 1) - + def maxRatePerPartition(topicPartition: TopicPartition): Long = maxRate def minRatePerPartition(topicPartition: TopicPartition): Long = minRate }