Flink DataSet-Programm erzeugt keine Ausgabe

Question

Ich versuche, das Ergebnis eines DataSet-API-Programms in eine Datei schreiben mit DataSet.writeAsText("file:///path/to/my/file").

Das Programm erzeugt jedoch keine Ausgabe. Die Ausgabedatei wird ebenfalls nicht erstellt. Was könnte der Grund dafür sein?

Answer 1

Haben Sie den Job ausgeführt, z. B. ExecutionEnvironment.execute()?

// get execution environment 
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); 

// Specify your program ... 
DataSet<X> ds1 = env... 
DataSet<Y> ds2 = ds1.map(...)... 
ds2.writeAsText(...); 

// execute the program 
env.execute();