Fix MIMA?

jeanlyn · May 14, 2015 · bb80bbb · bb80bbb
1 parent 5c30360
commit bb80bbb
Showing 1 changed file with 1 addition and 2 deletions.
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
@@ -62,8 +62,7 @@ class DirectKafkaInputDStream[
     val fromOffsets: Map[TopicAndPartition, Long],
     messageHandler: MessageAndMetadata[K, V] => R
 ) extends InputDStream[R](ssc_) with Logging {
-
-  private val maxRetries = context.sparkContext.getConf.getInt(
+  val maxRetries = context.sparkContext.getConf.getInt(
     "spark.streaming.kafka.maxRetries", 1)
 
   protected override val customScopeName: Option[String] = Some(s"kafka direct stream [$id]")