Flink 在日志文件夹中生成文件，但不打印任何内容

Question

我正在使用并行度 = 1 的 Flink 本地模式。

在我的 Flink 代码中，我尝试使用以下方法打印传入的源代码：

DataStream<String> ds = env.addSource(source);
ds.print();

在我的本地 Flink_dir/log 文件夹中，我可以看到已创建一个 xxx.out 文件，但没有打印到文件中。是否有任何我可能忽略的配置？我确定我的源数据包含文本，因为我已成功将数据添加到接收器。谢谢！

Answer 1

ds.print将写入标准输出而不是文件。 ${flink_dir}/log 仅包含任务和/或作业管理器的日志。