ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pragmaticbigdata <amits...@gmail.com>
Subject ClassNotFoundException with affinity run
Date Wed, 01 Jun 2016 14:27:32 GMT
I am trying to execute a compute task on the node where the data is located
following the example shown here -

I get an java.lang.ClassNotFoundException:
com.ignite.model.productdetails.ProductDetails though. The detailed
exception is listed here - http://pastebin.com/ijjvTBpj

Note that the code executes if not executed with
ignite.compute().affinityRun() and the ProductDetails class implements

What could be missing?

Another question I had about affinityRun was - how can I update a method
local variable in the IgniteRunnable.run() method? 

for e.g. 

private void updateColumnWithAffinity(UpdateTracker updateTracker,
Map.Entry<ColumnDependenciesVertex, RuntimeEdgeInfo> columnEntry) {
        for(Object key :
columnEntry.getValue().getUpdateInfo().getOutgoingDependencyValues()) {
            ignite.compute().affinityRun(productCache.getName(), key, () ->
                *//here's where the ClassNotFoundException occurs.*
String.valueOf(key), productCache.localPeek(String.valueOf(key)));

                *//what would be implications of the below statement? Would
it perform the update even executing on the remote node?*

Let me know your thoughts. Thanks.

View this message in context: http://apache-ignite-users.70518.x6.nabble.com/ClassNotFoundException-with-affinity-run-tp5359.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

View raw message