Flink调试或查看中间结果保姆级教程（持续更新）

在使用Flink进行实时流计算时，开发阶段需要调试和查看中间结果，看写的逻辑对不对。上线后如果发现有问题，或者实时数仓计算的数据跟离线数仓计算结果互相打架，需要查看中间结果和离线数仓对数据。可以通过以下几种方式查看流计算过程中的中间结果：

1. **使用

DataStream.print()

打印中间结果**

Flink 提供了

DataStream.print()

方法，可以直接在流处理过程中打印中间结果。这是最简单的一种方式，特别适用于本地开发和调试。

print()

会将结果打印到标准输出，默认情况下会显示线程信息和数据。

示例：

DataStream<String> input = env.fromElements("flink", "stream", "processing");
DataStream<String> upperCase = input.map(String::toUpperC