apache-flink

5ısı

1cevap

Apache Flink SNAPSHOT öğeleri nasıl içe aktarılır?

benim projeye Gelly belgelerini eklemek istiyorum, ama bana bu hata veriyor: Sources not found for: org.apache.flink:flink-gelly_2.10:1.2-SNAPSHOT Bu benim pom.xml <dependency> <groupId>org.apach

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

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.

0ısı

1cevap

flink 3 params

Ben https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/libs/ml/multiple_linear_regression.html örneğini takip fakat örnekte uyum fonksiyonu yalnızca bir param gerekir, ancak benim

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

5ısı

1cevap

Apache Flink veri akışından kullanım değerleri dinamik olarak ben aşağıdakileri yapar Apache FLINK kullanarak örnek bir uygulama oluşturmak çalışıyorum

bir akış veri kaynağı oluşturmak için: stok sembollerin bir demetini okur (örn Kafka kuyruğundan 'CSCO', 'FB'). Her sembol için, geçerli fiyatların gerçek zamanlı olarak araştırılması gerçekleştirilir

1ısı

1cevap

sorunsuz (bir JobManager ve birkaç TaskManagers ile) Apache Flink kurulumunu standalone için ben akışını dağıtabilir Flink CLI

kullanarak Apache Flink HA kümeye akışını dağıtmak olamaz ------------------------------------------------------------ The program finished with the following exception: org.apache.flink.client.pro

7ısı

1cevap

Pencere akışından bağımsız olarak iki akışını Apache Flink'te birleştirin

Birleştirmek istediğim iki veri akışım var. Sorun, bir veri akışının diğerinden daha yüksek bir frekansa sahip olmasıdır ve bir akımın hiç bir zaman olay almadığı zamanlar vardır. Son olayı bir akışta