流式实时水印传播具有以下限制:
不支持多个洗牌
只有一个洗牌运算符允许在调用与Watermark和有状态运算符之间使用,但发现 <shuffleCount>。
在水印之前不支持洗牌 (SHUFFLE_NOT_SUPPORTED_BEFORE_WATERMARK)
在调用 withWatermark 方法之前,不允许使用 Shuffle 运算符。
流式实时水印传播具有以下限制:
只有一个洗牌运算符允许在调用与Watermark和有状态运算符之间使用,但发现 <shuffleCount>。
在调用 withWatermark 方法之前,不允许使用 Shuffle 运算符。