From bb80bbb10d1b716c047f9ab864e6889997b54536 Mon Sep 17 00:00:00 2001 From: Andrew Or Date: Thu, 14 May 2015 11:09:05 -0700 Subject: [PATCH] Fix MIMA? --- .../apache/spark/streaming/kafka/DirectKafkaInputDStream.scala | 3 +-- 1 file changed, 1 insertion(+), 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 index cbafb6ad78c97..6b44eea998ec2 100644 --- 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]")