Flink DataSet程序不會產生輸出

Question

我正在嘗試使用DataSet.writeAsText("file:///path/to/my/file")將DataSet API程序的結果寫入文件。

但是，該程序不會產生任何輸出。輸出文件也不會被創建。這可能是什麼原因？

Answer 1

您是否執行了這項工作，即致電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();