diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2015-01-22 01:38:09 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-01-22 01:38:09 -0800 |
| commit | 5d07488adc074ff8d5a10980dfc25cd2d33d0cf0 (patch) | |
| tree | 9f73e3cab688493c352711b48708435b6e36c352 | |
| parent | cab410c529aeabaffa73298bd5a58f2f5bd4f008 (diff) | |
| download | spark-5d07488adc074ff8d5a10980dfc25cd2d33d0cf0.tar.gz spark-5d07488adc074ff8d5a10980dfc25cd2d33d0cf0.tar.bz2 spark-5d07488adc074ff8d5a10980dfc25cd2d33d0cf0.zip | |
[HOTFIX] Fixed compilation error due to missing SparkContext._ implicit conversions.
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala index 4f99886973..7a981098df 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala @@ -24,6 +24,7 @@ import scala.language.existentials import akka.actor._ import org.apache.spark.{Logging, SerializableWritable, SparkEnv, SparkException} +import org.apache.spark.SparkContext._ import org.apache.spark.streaming.{StreamingContext, Time} import org.apache.spark.streaming.receiver.{CleanupOldBlocks, Receiver, ReceiverSupervisorImpl, StopReceiver} |