Search code examples
apache-sparkignite

Error in ignite context creation

Hi i have just started exploring Apache-Ignite and facing a error initially in ignite context creation--

import org.apache.ignite.spark._
import org.apache.ignite.configuration._
val ic = new IgniteContext[Integer, Integer](sc, () => new IgniteConfiguration())
#Error:
 <console>:30: error: org.apache.ignite.spark.IgniteContext does not take type parameters
   val ic = new IgniteContext[Integer, Integer](sc, () => new IgniteConfiguration())

But every where on internet this line works(as it shows in examples provided).

Versions- apache-ignite-1.8.0-src, spark-2.0.2-bin-hadoop2.7

And I am starting the shell by 

./bin/spark-shell  --packages org.apache.ignite:ignite-spark:1.7.0, org.apache.ignite:ignite-spring:1.8.0 --master local  --repositories http://repo.maven.apache.org/maven2/org/apache/ignite

Can somebody help me with this error. Thanks.

Solution

  • Type arguments was removed in Ignite 1.7 according to that task.

    Just change to val ic = new IgniteContext(sc, () => new IgniteConfiguration())