如果更新非常频繁,又要保证关联的准确性,又要保证吞吐,那么最佳的解决方案我觉得只能是关联 changelog 了, 只是 Flink 目前还没有原生支持维表关联一个 changelog,会在Flink SQL 1.12中去支持。
当前版本下的话,可以尝试 keyby+localcache+异步IO。 Best, Jark On Tue, 16 Jun 2020 at 22:35, 李奇 <359502...@qq.com> wrote: > 或者采用redis做维表存储介质。 > > > 在 2020年6月16日,下午10:10,wangxiangyan <wangxiang...@dutinn.com> 写道: > > > > hi,大家 > > 维表被频繁更新,数据量1g左右,需要频繁同步,使用什么方案去关联比较好呢? >