Fix the MIMA failed test bya adding a default impl for minRate function

apache · Aug 27, 2018 · 85ece1c · 85ece1c
1 parent 2b0b1ce
commit 85ece1c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/...al/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala b/...al/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala
@@ -34,7 +34,7 @@ abstract class PerPartitionConfig extends Serializable {
    *  from each Kafka partition.
    */
   def maxRatePerPartition(topicPartition: TopicPartition): Long
-  def minRatePerPartition(topicPartition: TopicPartition): Long
+  def minRatePerPartition(topicPartition: TopicPartition): Long = 1
 }
 
 /**
@@ -46,5 +46,5 @@ private class DefaultPerPartitionConfig(conf: SparkConf)
   val minRate = conf.getLong("spark.streaming.kafka.minRatePerPartition", 1)
 
   def maxRatePerPartition(topicPartition: TopicPartition): Long = maxRate
-  def minRatePerPartition(topicPartition: TopicPartition): Long = minRate
+  override def minRatePerPartition(topicPartition: TopicPartition): Long = minRate
 }
diff --git a/...afka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/DirectKafkaStreamSuite.scala b/...afka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/DirectKafkaStreamSuite.scala
@@ -543,7 +543,6 @@ class DirectKafkaStreamSuite
         } else {
           100
         }
-      def minRatePerPartition(tp: TopicPartition) = 1
     })
     val kafkaStream = getDirectKafkaStream(topic, rateController, ppc)