0
我正在尝试使用DataSet.writeAsText("file:///path/to/my/file")
将DataSet API程序的结果写入文件。Flink DataSet程序不会产生输出
但是,该程序不会产生任何输出。输出文件也不会被创建。这可能是什么原因?
我正在尝试使用DataSet.writeAsText("file:///path/to/my/file")
将DataSet API程序的结果写入文件。Flink DataSet程序不会产生输出
但是,该程序不会产生任何输出。输出文件也不会被创建。这可能是什么原因?
您是否执行了这项工作,即致电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();
已经修好了,就像你说的一样 –
你能提供更多细节并粘贴代码片段吗?没有进一步的信息,就不可能回答这个问题。 –