可以考虑调小cache.ttl On Wed, Apr 15, 2020 at 11:22 AM tingli ke <[email protected]> wrote:
> 是否有其他的方式来对mysql维表数据进行实时join > > > [email protected] <[email protected]> 于2020年4月15日周三 上午11:08写道： > > > 有个setCacheMaxSize(1000)，可以改成 -1 表示不使用cache > > org.apache.flink.api.java.io.jdbc.JDBCLookupFunction 这个方法有解释 > > The cacheMaxSize is -1 means not use cache > > > > > > > > [email protected] > > > > 发件人： tingli ke > > 发送时间： 2020-04-15 10:55 > > 收件人： user-zh > > 主题： JDBCLookupFunction被缓存导致数据的不及时性 > > Hi, > > > > > 流表通过JDBCLookupFunction来对mysql的维表数据进行实时join，但是JDBCLookupFunction会对数据进行缓存，导致mysql的维表数据被更新，但是flink还是老的数据，(考虑性能需要被缓存) > > 是否有其他的方式来对mysql维表数据进行实时join > > > -- Regards, DinoZhang
