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