I set up the following lookup cache values:

'lookup.cache.max-rows' = '200000'
'lookup.cache.ttl' = '1min'

for a jdbc connector.

This table currently only has about 20000 records in it. However,
since I set the TTL to 1 minute, I expected the job to query that
table every minute.

The documentation states:

https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/jdbc.html#lookup-cache

The oldest rows in cache will be expired when the cache hit to the max
cached rows lookup.cache.max-rows or when the row exceeds the max time
to live lookup.cache.ttl.

What am I misunderstanding?

Reply via email to