Flink Table流式环境下JDBC lookup.cache相关配置不生效问题

流式环境中执行流数据与JDBC表的关联SQL时，JDBC表对应的任务读取完所有记录后立即终止。已配置lookup.cache、lookup.partial-cache.max-rows、lookup.partial-cache.expire-after-write等参数，但任务生命周期未改变，lookup缓存机制未按预期生效。

JDBC表创建语句如下：

CREATE  TABLE U_ZRB_C_RISKLI_MCC_0 (RISKLIMCC  STRING ,PRIMARY KEY (RISKLIMCC) NOT ENFORCED) 
  WITH ('connector' = 'jdbc' 
,'url' = 'jdbc:oracle:thin:@localhost:1521/orcl' 
,'table-name' = 'U_ZRB_C_RISKLI_MCC_0' 
,'driver' = 'oracle.jdbc.OracleDriver' 
,'username' = 'username' 
,'password' = 'password' 
,'lookup.cache'='PARTIAL'
,'lookup.partial-cache.expire-after-write'='10s')

• 确保关联查询使用维表lookup语法：流式场景下，JDBC表必须作为维表与流表关联，需使用FOR SYSTEM_TIME AS OF绑定流的处理时间，示例写法：

  SELECT s.*, u.RISKLIMCC
  FROM stream_table s
  LEFT JOIN U_ZRB_C_RISKLI_MCC_0 FOR SYSTEM_TIME AS OF s.proctime u
  ON s.mcc = u.RISKLIMCC;
  

  若直接读取JDBC表（而非作为维表关联），Flink会将其当作批处理任务，读完数据即终止。

• 补充完整缓存配置：当前配置缺少lookup.partial-cache.max-rows，需显式设置缓存最大行数（如'lookup.partial-cache.max-rows'='1000'），该参数控制缓存的上限，未设置时可能导致缓存逻辑不触发。

• 确认任务运行模式：提交任务时需指定execution.runtime-mode=STREAMING，若使用批处理模式（BATCH），JDBC表会被批量读取，缓存机制不生效。

• 检查Flink与驱动版本：使用Flink 1.13及以上版本（partial缓存特性在该版本后稳定支持），同时确保Oracle JDBC驱动版本与数据库版本匹配（如Oracle 12c+使用ojdbc8），避免兼容性问题。

内容的提问来源于stack exchange，提问作者Mustafa İrfan Değerli