Suchergebnisse für Anfrage "apache-flink"
Flink Scala API "nicht genug Argumente"
Ich habe Probleme mit der Apache Flink Scala API Selbst wenn ich zum Beispiel die Beispiele aus der offiziellen Dokumentation entnehme, gibt mir der Scala-Compiler Unmengen von Kompilierungsfehlern. Code object TestFlink { def main(args: ...
Was bedeutet "Streaming" in Apache Spark und Apache Flink?
ls ich zu @ giApache Spark Streaming [https://spark.apache.org/streaming/] Website, ich habe einen Satz gesehen: Spark Streaming erleichtert das Erstellen skalierbarer fehlertoleranter Streaming-Anwendungen. Und inApache Flink ...
Apache Flink-Streaming im Cluster teilt Jobs nicht mit Workern auf.
Mein Ziel ist es, einen Hochdurchsatz-Cluster mit Kafka als Quelle und Flink als Stream-Processing-Engine einzurichten. Folgendes habe ich getan: Ich habe auf dem Master und dem Slave einen 2-Knoten-Cluster mit der folgenden Konfiguration ...
Globale Sortierung in Apache Flink
ie @sortPartition-Methode eines Datasets sortiert das Dataset lokal anhand einiger angegebener Felder. Wie kann ich meinen großen Datensatz in Flink effizient global sortieren?
Ist es möglich, Riak CS mit Apache Flink zu verwenden?
Ich möchte @ konfigurierfilesystem State Backend undzookeeper Wiederherstellungsmodus state.backend: filesystem state.backend.fs.checkpointdir: ??? recovery.mode: zookeeper recovery.zookeeper.storageDir: ??? Wie Sie sehen, sollte ich ...
So kombinieren Sie Streaming-Daten mit umfangreichen Verlaufsdaten in Dataflow / Beam
Ich untersuche die Verarbeitung von Protokollen aus Webbenutzersitzungen über Google Dataflow / Apache Beam und muss die Protokolle des Benutzers beim Eingang (Streaming) mit dem Verlauf der Sitzung eines Benutzers aus dem letzten ...
Flink CEP Keine Ergebnisse gedruckt
Ich versuche, eine Zeichenfolge auszudrucken, wenn Hello und world mithilfe der Flink CEP-Bibliothek gefunden werden. Meine Quelle ist Kafka und ich benutze den Konsolenhersteller, um die Daten einzugeben. Dieser Teil funktioniert. Ich ...
flink - mit Dolchinjektionen - nicht serialisierbar?
Im mit Flink (neueste via Git), um von Kafka zu Cassandra zu streamen. Um das Testen von Einheiten zu vereinfachen, füge ich die Abhängigkeitsinjektion über Dagger hinzu. Der ObjectGraph scheint sich ordnungsgemäß einzurichten, aber die ...
Wie kann ich die Flink Job Manager-Weboberfläche starten, wenn Flink von einer IDE aus ausgeführt wird?
Ich möchte auf die Flink-Weboberfläche zugreifen, wenn ich sie lokal von der IDE aus starte. Ich brauche das, weil ich auf die Zähler (Akkumulatoren) von Flink zugreifen möchte.
Local Flink config läuft Standalone von IDE
Wenn ich eine Flink-App lokal direkt in Intellij ausführen möchte, aber Konfigurationsparameter angeben muss (z. B. fs.hdfs.hdfssite, um den S3-Zugriff einzurichten), können diese Konfigurationsparameter auch auf andere Weise bereitgestellt ...
Seite 1 von 2