Have you created a class called SQLContextSingleton ? If so, is it in the
compile class path?
On Fri, Apr 10, 2015 at 6:47 AM, Mukund Ranjan (muranjan) <
muran...@cisco.com> wrote:
> Hi All,
>
>
> Any idea why I am getting this error?
>
>
>
>
>
> wordsTenSeconds.foreachRDD((rdd: RDD[String], time: Time) => {
>
>
>
> val sqlContext = SQLContextSingleton.getInstance(rdd.sparkContext)
> // This line is creating this error
>
>
>
> })
>
>
>
> ————————————————— E R R O R ——————————
>
>
>
> [error]
> /Users/muranjan/workspace/kafka/src/main/scala/kafka/KafkaConsumer.scala:103:
> not found: value SQLContextSingleton
>
> [error] val sqlContext =
> SQLContextSingleton.getInstance(rdd.sparkContext)
>
> [error] ^
>
> [error]
> /Users/muranjan/workspace/kafka/src/main/scala/kafka/KafkaConsumer.scala:158:
> not found: value SQLContextSingleton
>
> [error] val sqlContext =
> SQLContextSingleton.getInstance(rdd.sparkContext)
>
> [error] ^
>
> [error] two errors found
>
> [error] (compile:compileIncremental) Compilation failed
>
>
>
> ————————————————— E R R O R ——————————
>
> Thanks,
> Mukund
>
