No I was talking about DM trunk. I'll have a look tomorrow.
Tommaso Teofili <[email protected]> schrieb: >I'm using current DM trunk (0.2-SNAPSHOT), or were you meaning Kryo >trunk? > >Regards, >Tommaso > >2013/7/18 Noctarius <[email protected]> > >> Hi Tammaso >> I guess this is fixed in the current trunk. >> >> Chris >> >> >> >> Tommaso Teofili <[email protected]> schrieb: >> >> >Hi all, >> > >> >I'm doing some tests on using Apache DM for HAMA-732 [1][2] where 4 >> >local >> >processes running locally in parallel should use a separate instance >of >> >a >> >CacheService. >> >When using Kryo I get this ConcurrentModificationException: >> > >> >ERROR bsp.BSPTask: Error running bsp setup and bsp function. >> >com.esotericsoftware.kryo.KryoException: >> >java.util.ConcurrentModificationException >> >Serialization trace: >> >classes (sun.misc.Launcher$AppClassLoader) >> >classLoader (org.apache.hama.HamaConfiguration) >> >conf (org.apache.hama.graph.AggregationRunner) >> >aggregationRunner (org.apache.hama.graph.GraphJobRunner) >> >runner (org.apache.hama.graph.example.PageRank$PageRankVertex) >> > at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer$ObjectField.write(FieldSerializer.java:585) >> >at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer.write(FieldSerializer.java:213) >> > at com.esotericsoftware.kryo.Kryo.writeObject(Kryo.java:501) >> >at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer$ObjectField.write(FieldSerializer.java:564) >> > at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer.write(FieldSerializer.java:213) >> >at com.esotericsoftware.kryo.Kryo.writeObject(Kryo.java:501) >> > at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer$ObjectField.write(FieldSerializer.java:564) >> >at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer.write(FieldSerializer.java:213) >> > at com.esotericsoftware.kryo.Kryo.writeObjectOrNull(Kryo.java:549) >> >at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer$ObjectField.write(FieldSerializer.java:570) >> > at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer.write(FieldSerializer.java:213) >> >at com.esotericsoftware.kryo.Kryo.writeObjectOrNull(Kryo.java:549) >> > at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer$ObjectField.write(FieldSerializer.java:570) >> >at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer.write(FieldSerializer.java:213) >> > at com.esotericsoftware.kryo.Kryo.writeObject(Kryo.java:486) >> >at >> >> >>org.apache.directmemory.serialization.kryo.KryoSerializer.serialize(KryoSerializer.java:68) >> > at >> >> >>org.apache.directmemory.cache.CacheServiceImpl.put(CacheServiceImpl.java:117) >> >at >> >> >>org.apache.directmemory.cache.CacheServiceImpl.put(CacheServiceImpl.java:109) >> > at >> >> >>org.apache.hama.graph.OffHeapVerticesInfo.addVertex(OffHeapVerticesInfo.java:79) >> >at >> >>org.apache.hama.graph.GraphJobRunner.loadVertices(GraphJobRunner.java:412) >> > at >org.apache.hama.graph.GraphJobRunner.setup(GraphJobRunner.java:102) >> >at org.apache.hama.bsp.BSPTask.runBSP(BSPTask.java:176) >> > at org.apache.hama.bsp.BSPTask.run(BSPTask.java:146) >> >at >> >>org.apache.hama.bsp.GroomServer$BSPPeerChild.main(GroomServer.java:1260) >> >Caused by: java.util.ConcurrentModificationException >> >at >> >>java.util.AbstractList$Itr.checkForComodification(AbstractList.java:372) >> >at java.util.AbstractList$Itr.next(AbstractList.java:343) >> > at >> >> >>com.esotericsoftware.kryo.serializers.CollectionSerializer.write(CollectionSerializer.java:74) >> >at >> >> >>com.esotericsoftware.kryo.serializers.CollectionSerializer.write(CollectionSerializer.java:18) >> > at com.esotericsoftware.kryo.Kryo.writeObject(Kryo.java:501) >> >at >> >> >>com.esotericsoftware.kryo.serializers.FieldSerializer$ObjectField.write(FieldSerializer.java:564) >> > ... 23 more >> > >> > >> >What do you think would be the recommended way of using DM in such a >> >setup? >> >May instead be a problem with Kryo? >> > >> >Thanks a lot in advance, >> >Tommaso >> > >> > >> >[1] : https://issues.apache.org/jira/browse/HAMA-732 >> >[2] : >> > >> >https://github.com/tteofili/hama/blob/HAMA-732/graph/src/main/java/org/apache/hama/graph/OffHeapVerticesInfo.java >> >> -- >> Diese Nachricht wurde von meinem Android-Mobiltelefon mit K-9 Mail >> gesendet. -- Diese Nachricht wurde von meinem Android-Mobiltelefon mit K-9 Mail gesendet.
