2017-04-20 7 views
1

Après la mise à niveau d'un service utilisant Akka + Akka sharding vers Akka (2.5.0), nous avons commencé à rencontrer des problèmes lors du démarrage du système dans Docker + Alpine Linux. De ce que je peux en déduire, Akka Cluster sharding est configuré pour utiliser Akka Distributed Data (qui n'est plus expérimental à partir de 2.5.0) et utilise LMDB (qui nécessite GCC + glibc et n'est pas disponible dans Alpine Linux).Akka 2.5 Données distribuées sur Docker + Alpine Linux

Mes questions sont les suivantes:

1) Existe-t-il une alternative standard pris en charge par Akka au lieu de LMDB?

2) Existe-t-il un moyen de faire fonctionner LMDB dans Alpine Linux?

Stack Trace:

[ERROR] [04/20/2017 13:42:19.014] [lotus-akka.actor.default-dispatcher-5] [akka://lotus/system/sharding/replicator/durableStore] Error relocating /tmp/lmdbjava-native-library-5972006786989102785.so: __fprintf_chk: symbol not found 
akka.actor.ActorInitializationException: akka://lotus/system/sharding/replicator/durableStore: exception during creation 
     at akka.actor.ActorInitializationException$.apply(Actor.scala:191) 
     at akka.actor.ActorCell.create(ActorCell.scala:600) 
     at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:454) 
     at akka.actor.ActorCell.systemInvoke(ActorCell.scala:476) 
     at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:282) 
     at akka.dispatch.Mailbox.run(Mailbox.scala:223) 
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
     at java.lang.Thread.run(Thread.java:745) 
Caused by: java.lang.reflect.InvocationTargetException 
     at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) 
     at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) 
     at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 
     at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 
     at akka.util.Reflect$.instantiate(Reflect.scala:65) 
     at akka.actor.ArgsReflectConstructor.produce(IndirectActorProducer.scala:96) 
     at akka.actor.Props.newActor(Props.scala:213) 
     at akka.actor.ActorCell.newActor(ActorCell.scala:555) 
     at akka.actor.ActorCell.create(ActorCell.scala:581) 
     ... 7 more 
Caused by: java.lang.UnsatisfiedLinkError: Error relocating /tmp/lmdbjava-native-library-5972006786989102785.so: __fprintf_chk: symbol not found 
     at jnr.ffi.provider.jffi.NativeLibrary.loadNativeLibraries(NativeLibrary.java:87) 
     at jnr.ffi.provider.jffi.NativeLibrary.getNativeLibraries(NativeLibrary.java:70) 
     at jnr.ffi.provider.jffi.NativeLibrary.getSymbolAddress(NativeLibrary.java:49) 
     at jnr.ffi.provider.jffi.NativeLibrary.findSymbolAddress(NativeLibrary.java:59) 
     at jnr.ffi.provider.jffi.AsmLibraryLoader.generateInterfaceImpl(AsmLibraryLoader.java:158) 
     at jnr.ffi.provider.jffi.AsmLibraryLoader.loadLibrary(AsmLibraryLoader.java:89) 
     at jnr.ffi.provider.jffi.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:43) 
     at jnr.ffi.LibraryLoader.load(LibraryLoader.java:325) 
     at jnr.ffi.LibraryLoader.load(LibraryLoader.java:304) 
     at org.lmdbjava.Library.<clinit>(Library.java:95) 
     at org.lmdbjava.Env$Builder.open(Env.java:406) 
     at org.lmdbjava.Env$Builder.open(Env.java:430) 
     at akka.cluster.ddata.LmdbDurableStore.<init>(DurableStore.scala:131) 
     ... 16 more 

Répondre

1

a finalement réussi à résoudre ce problème. Le partitionnement de cluster tente d'utiliser le stockage durable par défaut (la valeur par défaut est LMDB). Pour la fragmentation de cluster sans utiliser remember-entities, un stockage durable n'est pas requis.

Par conséquent, la solution à c'était pour désactiver le stockage durable pour sharding de cluster en ajoutant la configuration suivante

akka.cluster.sharding.distributed-data.durable.keys = [] 
+0

Une autre option serait d'utiliser un journal de persistance pour persister l'état sharding, voir plus dans les docs: http://doc.akka.io/docs/akka/2.5.0/scala/cluster-sharding.html#persistence-mode – johanandren

+0

J'ai considéré cette option mais comme nous n'utilisons pas 'remember-entities', il n'y a pas t toute valeur dans la persistance de l'état de partitionnement – aseychell

+0

Si le noeud avec le coordinateur de fragmentation plante l'état (les fragments sont sur quelles régions de partition) doit être récupéré sur le nouveau coordinateur de partition au démarrage. – johanandren