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.
