apache-flink

2Hitze

1Antwort

konnte nicht impliziten Wert für Beweise Parameter finden

Ich bin ein einfacher Wortzählimpuls flink Job zu schreiben, aber ich halte diesen Fehler: could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInforma

0Hitze

1Antwort

Apache Flink: "Fehler beim Auslösen eines Prüfpunkts als Ergebnis des Empfangs der Prüfpunktbarriere"

Sporadisch Ausnahmen wie folgt. java.lang.RuntimeException: Error triggering a checkpoint as the result of receiving checkpoint barrier at org.apache.flink.streaming.runtime.tasks.StreamTask$2.on

3Hitze

1Antwort

java.lang.NoSuchMethodError: scala.Predef $ .ArrowAssoc (Ljava/lang/Objekt;) Ljava/lang/Objekt

Ich arbeite mit flink und kafka, ich habe diesen Fehler. java.lang.NoSuchMethodError: scala.Predef$.ArrowAssoc(Ljava/lang/Object;)Ljava/lang/Object; at kafka.consumer.FetchRequestAndResponseMetri

0Hitze

1Antwort

Ein Flink-Dataset durch Schlüssel in Vielfache aufteilen und in separate Dateien schreiben

Ich möchte meine DataSet<Tuple2<Integer, Point>> in n DataSets nach dem Integer-Wert des Tuple2 teilen. Derzeit filtere ich im Grunde die Datei n-mal und speichern jedes Ergebnis in einer separaten Da

3Hitze

3Antwort

Flink Fehler: Schlüssel über Feldpositionen zu spezifizieren gilt nur für Tupeldatentypen

Ich benutze die Scala API von Flink. Ich habe einige Transformationen über eine reports = DataStream[Tuple15] (die Tuple15 ist eine Scala Tuple und alle Felder sind Int). Die Frage ist hier zu finden:

0Hitze

1Antwort

flink Lesen von Daten aus kafka

ich ein einfaches Beispiel schreiben val env = StreamExecutionEnvironment.getExecutionEnvironment val properties = new Properties() properties.setProperty("bootstrap.servers","xxxxxx") properties.s

1Hitze

1Antwort

Ho kann ich ein faules Spiel mit Flink CEP machen

Ich möchte mit FlinkCEP nur ein "faules" Spiel auf einem Muster machen. Wie kann ich das machen? z.B. Ich habe einen Eingabestrom ACABCABCB und ich möchte auf A gefolgt von C übereinstimmen, um nur 3

1Hitze

2Antwort

Wie Sie verschiedene log4j.properties-Dateien für verschiedene flink-Jobs angeben, die auf demselben Standalone-Cluster ausgeführt werden

Ich habe mehrere flink-Jobs auf einem eigenständigen Cluster ausgeführt. Ich möchte verschiedene Protokolldateien für verschiedene Flink-Jobs. Also, wie kann ich verschiedene log4j.properties Datei üb

1Hitze

1Antwort

Flink: keine äußeren Joins auf DataStream?

Ich war überrascht, dass es keine äußeren Verbindungen für DataStream in Flink (DataStream docs) gibt. Für DataSet Sie haben alle Möglichkeiten: leftOuterJoin, rightOuterJoin und fullOuterJoin, abgese

0Hitze

1Antwort

Apache Flink - groupBy

Ich versuche, die erste Übung auf http://dataartisans.github.io/flink-training/exercises/ zu folgen. Jetzt komme ich zu dem folgenden Problem. Was gibt mir die groupBy Funktion zurück? Und wie transfo