I'm using a single node Ignite (starting it as ./ignite.sh -J-Xmx10g) with
the following configuration:
<bean id="grid.cfg"
class="org.apache.ignite.configuration.IgniteConfiguration">
<property name="gridName" value="VaRGrid" />
<property name="peerClassLoadingEnabled" value="true"/>
<property name="discoverySpi">
<bean
class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<bean
class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
<property name="addresses">
<list>
<value>vm-9979-89ff:47500..47509</value>
</list>
</property>
</bean>
</property>
</bean>
</property>
</bean>
My client application is started on the same host as a Spark application by
using spark-submit. The client code is attempting to use IgniteRDD but,
first, it has to connect to Ignite cluster:
*val igContext = new IgniteContext[Int, List[Double]](sc,
"default-config.xml")*
val igCacheCfg = new CacheConfiguration[Int,
List[Double]]("moves_cache")
val cacheIgRDD = igContext.fromCache(igCacheCfg)
if (cacheIgRDD.count == 0) {
val movesRDD = sc.textFile(movesPath)
.filter(x =>
!VaRUtils.isHeader(x)).map(_.split("\\|"))
.map(k => (k(0).toInt,
k(1).split(",").map(_.toDouble).toList))
cacheIgRDD.savePairs(movesRDD, true)
}
It fails at the line that creates IgniteContext. The default-config.xml has
the same settings as the cluster configuration. The driver exception trace
is this:
16/05/18 10:07:11 INFO XmlBeanDefinitionReader: Loading XML bean definitions
from URL [jar:file:/tmp/VaR-0.0.1-SNAPSHOT-1.5.0.jar!/default-config.xml]
16/05/18 10:07:11 INFO GenericApplicationContext: Refreshing
org.springframework.context.support.GenericApplicationContext@68939508:
startup date [Wed May 18 10:07:11 EDT 2016]; root of context
hierarchy
Exception in thread "main" class
org.apache.ignite.IgniteIllegalStateException: Ignite instance with provided
name doesn't exist. Did you call Ign ition.start(..) to start an
Ignite instance? [name=VaRGrid]
at org.apache.ignite.internal.IgnitionEx.grid(IgnitionEx.java:1235)
at org.apache.ignite.Ignition.ignite(Ignition.java:516)
at
org.apache.ignite.spark.IgniteContext.ignite(IgniteContext.scala:150)
at
org.apache.ignite.spark.IgniteContext.<init>(IgniteContext.scala:62)
at
org.apache.ignite.spark.IgniteContext.<init>(IgniteContext.scala:88)
at
training.VaRIgniteUtils$.getMovesForVersion(VaRIgniteUtils.scala:19)
at training.VaRCalculatorStream$.main(VaRCalculatorStream.scala:61)
at training.VaRCalculatorStream.main(VaRCalculatorStream.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at
org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:672)
at
org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:180)
at
org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:205)
at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:120)
at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)
What would be the reason for this?
Thank you
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Error-creating-IgniteContext-Ignite-instance-with-provided-name-doesn-t-exist-tp5021.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
