为了更快的定位您的问题,请提供以下信息,谢谢
【详述】使用flink connector的look up维表时,发现StarRocksDynamicLookupFunction直接加载全部数据,影响使用;同时,代码里有StarRocksDynamicLRUFunction类,里面会根据key来where,能解决该问题,却没有使用这个实现
【背景】使用starrocks作为lookup维表
【业务影响】遇到大的维表,就无法使用flink connector内置的look up能力
【是否存算分离】不影响该问题
【StarRocks版本】2.3.7 43fbd55
【connector版本】flink-connector 1.2.6_flink-1.14_2.11
【集群规模】不影响该问题
【机器信息】不影响该问题
【联系方式】mayaming1983@gmail.com
【附件】
见代码实现:
com.starrocks.connector.flink.table.source.StarRocksDynamicLookupFunction
com.starrocks.connector.flink.table.source.StarRocksDynamicLRUFunction