ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From percent620 <percent...@163.com>
Subject Re: Yarn deployment for static TcpDiscoverySpi issues:Urgent In Production
Date Tue, 23 Aug 2016 09:20:31 GMT
This is my java code as below
1)
val igniteContext = new IgniteContext[Integer, Integer](sc,
"/u01/xxxx/apache-ignite-fabric-1.6.0-bin/config/default-config.xml")
    println("define igniteContext end===")
    val sharedRDD = igniteContext.fromCache("sharedBaselineCacheRDD")
    //val sharedRDD = igniteContext.fromCache(new
CacheConfiguration[Integer, Integer]().setCacheMode(CacheMode.REPLICATED))

    val initalRDD = sc.parallelize(1 to 100000,10).map(i => (new Integer(i),
new Integer(i)))
    println("initalRDD.couner=/. " + initalRDD.count() +"\tpartition=> " +
initalRDD.partitions.size)

    sharedRDD.savePairs(initalRDD, true)
    println("=====>totalcounter" + sharedRDD.count + "\t paris => " +
sharedRDD.partitions.size)
    println("=====>" + sharedRDD.filter(_._2 > 50000).count)


2) my ignite default.xml configuration is static IP NOT mulicast



--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Yarn-deployment-for-static-TcpDiscoverySpi-issues-Urgent-In-Production-tp7205p7238.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Mime
View raw message