apache-flink

0Hitze

1Antwort

Einen Stream mit einem anderen Stream anreichern

Ich möchte Apache Flink für Folgendes verwenden. Ich habe einen Hauptstrom, der mit den Daten eines anderen Streams angereichert werden muss. Dieser Hauptstrom hat Elemente mit den Attributen "site" u

1Hitze

1Antwort

Flink Batch: Daten lokale Planung auf HDFS?

wir haben ein bisschen mit Flink gespielt. Bisher haben wir Spark und Standard-M/R auf Hadoop 2.x/YARN verwendet. Abgesehen von dem Flink-Ausführungsmodell auf YARN ist dieses AFAIK nicht dynamisch wi

0Hitze

1Antwort

Flink Gelly Pfad/Pfad Usecase

Unser Team ist neu in Gelly api. Wir versuchen, einen einfachen Anwendungsfall zu implementieren, der alle Pfade auflistet, die von einem anfänglichen Vertex stammen - z. Eingangskante CSV-Datei ist 1

1Hitze

1Antwort

flink - Zeppelin - antwortet nicht

Ich kann flink (1.0.3) Prozess in Zepplin nicht ausführen. Es steht aus und WebUi zeichnet den Prozess nicht auf: sowohl im Cluster- als auch im lokalen Modus. Flink selbst funktioniert gut in der Bef

0Hitze

1Antwort

Flink - Datastream Typ Konvertierung - Fehler

Ich versuche, die verarbeitete Wordcount in Flink zu einem Kafka-Thema zu schreiben. Fehler --- "Die Methode addSink (SinkFunction>) in der Art Datastream> für die Argumente nicht anwendbar ist (Flink

3Hitze

2Antwort

Wie Kafka Nachrichten mit Avro und Flink zu entschlüsseln

Ich versuche AVRO Daten aus einem Kafka Thema mit Flink 1.0.3 zu lesen. Ich weiß nur, dass dieses spezielle Kafka-Thema AVRO codierte Nachricht hat und ich habe die AVRO-Schemadatei. My Flink code: pu

1Hitze

1Antwort

Apache Flink DataSet Differenz-/Subtraktionsoperation

Ich versuche derzeit einige Algorithmen in Apache Spark und Apache Flink zu implementieren. Bei der Ausführung der Algorithmen muss ich eine Art von Differenz-/Subtraktionsoperationen durchführen. Wäh

0Hitze

1Antwort

Apache Flink - Summe und gruppiert halten

Angenommen, ich habe Datensätze wie folgt aus: ("a-b", "data1", 1) ("a-c", "data2", 1) ("a-b", "data3", 1) Wie kann ich Gruppe und die Summe in Apache Flink, so dass ich die folgenden Ergebnisse h

1Hitze

1Antwort

Apache Flink + CEP - Erkenne gleiche Ereignisse

Ich möchte Ereignisse mit derselben Eigenschaft erkennen. Angenommen, ich habe einen einfachen Fall Klasse: case class Record(name: String, value: Int) Angenommen, es ist der folgende Strom: Record(

0Hitze

1Antwort

Verwenden von JNI-Bibliotheken in Flink-Cluster

Ich brauche JNI-Bibliotheken, um das Glas auf Flink-Cluster auszuführen. Kann mir bitte jemand sagen, wie man das macht? Wenn es mithilfe von VM-Argumenten bereitgestellt werden soll, wie VM-Argumente