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();