用 Async + Discarding sink 替代 Flink Sink 缓解背压
Replace Flink Sink with Async + Discarding sink to alleviate backpressure
我有一个项目将数据发送到 Sink，有时响应时间太长，导致前面所有步骤出现背压。
我想知道用 Async 函数替换 Sink + Discarding Sink 是否有助于解决这个背压问题。
有没有更好的替代方法？
我怀疑您可能会更好地实现基于 FLIP-171: Async Sink. This will be included in Flink 1.15, see [FLINK-24041] Generic AsyncSinkBase 的自定义接收器。
我有一个项目将数据发送到 Sink，有时响应时间太长，导致前面所有步骤出现背压。 我想知道用 Async 函数替换 Sink + Discarding Sink 是否有助于解决这个背压问题。 有没有更好的替代方法？
我怀疑您可能会更好地实现基于 FLIP-171: Async Sink. This will be included in Flink 1.15, see [FLINK-24041] Generic AsyncSinkBase 的自定义接收器。