/asked by John Smith/
Until Unions are fixed I am trying to broadcast my query in parallel on all
nodes. But I get serialization exception...
/class org.apache.ignite.IgniteCheckedException: Failed to serialize object:
[Entry [key=10000018, val=MyTrx [field1=10000018, field2=100080,
fullName=John Smith]]] at
org.apache.ignite.marshaller.optimized.OptimizedMarshaller.marshal(OptimizedMarshaller.java:186)/
Exeption only happens on remote nodes.
I set up my cache as follows...
/IgniteConfiguration igniteCfg = new IgniteConfiguration();
igniteCfg.setMarshaller(new OptimizedMarshaller(true));
CacheConfiguration<Long, com.xxx.model.Transaction> cfg = new
CacheConfiguration<>("myCache");
cfg.setCacheMode(CacheMode.PARTITIONED);
cfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
cfg.setBackups(0);
cfg.setIndexedTypes(Long.class, com.xxx.model.MyTrx.class);
ignite = Ignition.start(igniteCfg);/
I run my queries as follows...
/IgniteCompute compute = ignite.compute().withAsync();
compute.broadcast(
(MyTrx myReq) -> {
System.out.println("Full Name!");
String sqlStr = "FROM Transaction WHERE fullName = ?";
SqlQuery sql = new SqlQuery(Transaction.class, sqlStr);
sql.setArgs(trxRequest.getFullName());
sql.setLocal(true);
HashSet<MyTrx> list = new
HashSet<MyTrx>(myCache.query(sql.setSql(sqlStr)).getAll());
return list;
}, trxRequest);
futs.add(compute.future());/
-----
/This post is migrated from now discontinued Apache Ignite forum at
http://apacheignite.readme.io/v1.0/discuss/
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Can-serialize-Entry-on-distributed-query-tp290.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
