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模式下没有 > > 陈 > > >
