apache-flink

0Hitze

1Antwort

Warum flink stoppt meine Stream-Anwendung?

Mein Code verwendet readTextFile, um Protokolldateien zu lesen, und wenn ich den jar in Flink (/opt/flink-1.0.3/bin/flink run -m yarn-cluster -yn 2 /home/flink/flink-json-0.1.jar) ausführe, verarbeite

1Hitze

1Antwort

Verwendung von Apache Flink und RxJava

Ich benutze derzeit Apache flink und mit RxJava drin, meine Fragen ist: Beide zu verwenden ist angebracht? weil meine flink-Operationen immer Kartenfunktionen sind und innerhalb von ihnen verwende ich

1Hitze

2Antwort

Apache Flink Fenster Bestellung

Mit Apache Flink möchte ich ein Streaming-Fenster erstellen, das nach dem im Kafka-Ereignis gespeicherten Zeitstempel sortiert ist. Laut dem folgenden Artikel ist dies nicht implementiert. https://cwi

3Hitze

2Antwort

Apache Flink: Wie werden späte Ereignisse gehandhabt?

Wenn ein Element ankommt, das die Wasserzeichenbedingung verletzt, wie wird das Ereignis behandelt? Ist es weggeworfen? Oder wird das Ereignis weiterhin mit nachfolgenden Fensterfunktionen, die mit de

0Hitze

1Antwort

Flink InvocationTargetException. Unzureichende Anzahl der Netzwerkpuffer

Dies ist ein Teil des ursprünglichen WordCount.java-Codes. public static void main(String[] args) throws Exception { // set up the execution environment final ExecutionEnvironment env = Exe

1Hitze

1Antwort

Python API Streaming-Beispiele für RabbitMQ auf Flink

Mit Flink anstelle von Spark. Erstens scheint es keine Beispiele zu geben, die die Python-API im Streaming-Modus verwenden. I.e. Gehen Sie hier, ich sehe keine: https://ci.apache.org/projects/flink/fl

0Hitze

1Antwort

Flink Streaming während Summe Ausnahme werfen Berechnung

Ich verwende Flink Streaming Beispiel, wo Racks zur Verfügung & I durch Rack IDs..following Summe von Temperatur Gruppe berechnet werden soll mein Code: static Properties properties=new Properties();

4Hitze

1Antwort

Durchschnitt berechnen mit Flink DataStream für eine Fensterdauer

Ich benutze Flink DataStream API, wo es Racks gibt & Ich möchte "Durchschnitt" der Temperaturgruppe nach Rack-IDs berechnen. Meine Fensterdauer beträgt 40 Sekunden. & mein Fenster gleitet alle 10 Seku

0Hitze

1Antwort

Gibt es eine Möglichkeit, die TaskManager-ID in einer Map in Apache Flink zu erhalten?

Mit der benutzerdefinierten Partitionierung in Apache Flink geben Sie einen Schlüssel für jeden Datensatz an, der einem bestimmten Taskmanager zugewiesen werden soll. Betrachten wir einen Datensatz an

0Hitze

1Antwort

/windowApache Flink-Kettenoperatoren

Ich begann mit Apache Flink für Web-Traffic-Analyse. Ich habe keine Möglichkeit gefunden, mehr als 1 Metrik über das Zeitfenster zusammenzufassen. im follwing Beispiel aggregiert die Code Verwendung e