Hi!

流作业中产生的数据有不同类型,例如插入(+I),删除(-D),更新(-U、+U),它们的具体说明见 [1]。print sink 实际上较多用于
debug,因此用户实际上不太需要关心这些 op 的含义。

批作业中产生的所有数据都是插入,因此不需要 op。

[1]
https://nightlies.apache.org/flink/flink-docs-release-1.14/api/java/org/apache/flink/types/RowKind.html

陈卓宇 <[email protected]> 于2021年11月18日周四 下午8:02写道:

> 在inStreamingMode会出现 首列op,行数据是+I
> 在inBatchMode模式下就没有
>
> 请问这个op列和+I是什么意思 为什么inStreamingMode模式下有而inBatchMode模式下没有
>
> 陈
>
>
> &nbsp;

回复