Projemizde, bir kafka kuyruğundan çıkan, bir harita işlevi dönüşümü gerçekleştiren ve başka bir sıraya yazan bir Flink (1.1.3) akış işine sahibiz.Flick ve Play 2.5 arasındaki Akka sürüm çakışması
Bu, akışın bir parçası olarak giden bir REST isteğini ekleyene kadar iyi çalışıyordu. Onu ve çalışan dağıtırken Bu lokal iyi çalıştı
val config = new AhcWSClientConfig(wsClientConfig = WSClientConfig())
val builder = new AhcConfigBuilder(config)
val ahcConfig = builder.configure().build()
new AhcWSClient(ahcConfig)(ActorMaterializer()(ActorSystem()))
ama: biz (bizim yığının diğer yerlerde kullanılır gibi) Play Framework WSClient kullanılan ve bu şekilde kodda oluşturulan Bunu yapmak için içine incelenmesi
java.lang.NoSuchMethodError: akka.util.Helpers$.toRootLowerCase(Ljava/lang/String;)Ljava/lang/String;
at akka.stream.StreamSubscriptionTimeoutSettings$.apply(ActorMaterializer.scala:491)
at akka.stream.ActorMaterializerSettings$.apply(ActorMaterializer.scala:243)
at akka.stream.ActorMaterializerSettings$.apply(ActorMaterializer.scala:232)
at akka.stream.ActorMaterializer$$anonfun$1.apply(ActorMaterializer.scala:41)
at akka.stream.ActorMaterializer$$anonfun$1.apply(ActorMaterializer.scala:41)
at scala.Option.getOrElse(Option.scala:121)
at akka.stream.ActorMaterializer$.apply(ActorMaterializer.scala:41)
at com.ourstuff.etl.core.utils.web.GlobalWSClient$.generateClient(WSClientFactory.scala:32)
Bu (Flink 1.1.x getirdiği) Akka 2.3.x ve (Play Framework getirdiği) Akka 2.4.x arasında bir çarpışma olduğu varsayılır: bir kümede, bu istisna var.
Bu sorunu çözeceği varsayılarak Flink kümesini 1.3.1'e yükselttik (kodun Flink'e olan bağımlılığı kadar). Fakat aynı sorun devam ediyor gibi görünüyor.
Buna neden olan şey hakkında bir fikrin var mı?
Flink 1.3.1 hala Akka 2.3 kullanıyor (teknik olarak flakka adı verilen özel bir 2.3 yapısı). –
@ChesnaySchepler, Flink 1.3.1'in akka (flaka) 'nın kendi özel versiyonunu kullanması nedeniyle, neden clathpath içinde akka'yı arayan bir oyunla bir çarpışma olacak? – JoefGoldstein
Sadece bunun üzerine güncelleştirmek için. sbt 'whatDependsOn" com.typesafe.akka "" akka-actor_2.11 "" 2.3.7 "' üzerinde koştum ve herhangi bir sonuç vermedi. – JoefGoldstein