flink-streaming

7ısı

1cevap

Flick ve Play 2.5 arasındaki Akka sürüm çakışması

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. Bu, akışın bir parçası olarak giden bir REST isteğini

1ısı

1cevap

flink Akış NoSuchMethodError: org.apache.flink.api.common.ExecutionConfig.setRestartStrategy

java.lang.NoSuchMethodError: org.apache.flink.api.common.ExecutionConfig.setRestartStrategy(Lorg/apache/flink/api/common/restartstrategy/RestartStrategies$RestartStrategyConfiguration;)V at com.W

0ısı

1cevap

Flink [Scala] 'da RollingSink kullanılarak Avro ile seri hale getirilmiş nesnelerin yazılması [Scala]

Flink'te RollingSink kullanılarak HDFS'ye seri hale getirilmiş vaka sınıfları yazmaya çalışıyorum. HDFS tarafından avro dosyaları deserialize edilebilir hale getirmek için FSDataOutputStream'ı saran D

0ısı

1cevap

Özel için kaydetme noktaları nasıl uygulanır?

Ben özel WindowAssigher uyguladık: public class SessionWindowAssigner extends WindowAssigner<LogItem, SessionWindow> { @Override public Collection<SessionWindow> assignWindows(LogItem elemen

2ısı

1cevap

Neden bir GlobalWindow örneği kullanılır? Bu <a href="https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/SessionWindowing.java" rel="nofollow">example</a> de

Görünüş: (GlobalWindows#assignWindows içinde oluşturulan) GlobalWindow bir örneğini kullanarak neden bu örnekte // We create sessions for each id with max timeout of 3 time units DataStream<Tuple3<St

1ısı

1cevap

Apache Flink başarısızlıktan sonra tetik zamanlayıcıları geri yükler mi?

Bazı özel tetikleyicilerin durumu ve zamanlayıcıları vardır (ör. this example). Hatadan sonra durumu will be restored anladığımdan ancak zamanlayıcılar nasıl olur? Arızalardan sonra otomatik olarak ge

10ısı

1cevap

Akışta benzersiz kelimeler nasıl sayılır?

Flink Akış ile bir akıştaki benzersiz kelimelerin sayısını saymanın bir yolu var mı? Sonuçlar, artmaya devam eden bir sayı akışı olacaktır.

2ısı

1cevap

Flink: Tek bir programda Veri Kümesi ve Datastream API'si. Mümkün mü?

Statik verileri önce veri kümesi API'sini kullanarak işlemek ve daha sonra bir akış işini yürütmek için DataStream API'sini kullanmak istiyorum. IDE'ye kod yazarsam, mükemmel çalışır. Ama yerel flink