Below is the corresponding code where ignite step was in hung state.
logInfo("Populating the canonical name Cache on Ignite Nodes")
val time = System.currentTimeMillis()
companyVORDD.mapPartitions(x => {
val kvs = x.map(comp =>
(comp.wcaId,comp)).toMap[String,CompanyVO].asJava
companyDao.nameCache.putAll(kvs)
x
}).count()
And for your information, many times we won't see any issues with this and
the hung state I mentioned aboveis happening only sometimes.
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
