flink-doris-connector lookup join支持flinksql匹配为空异步延迟重试语法么?

Viewed 57

情况:使用flinksql lookup join doris实时维度表,由于维度表有延迟,根据flinksql hints语法,在sql上增加了匹配为空,异步延迟重试相关语法,但是看输出的数据,lookup join为空的数据并没有进行重试,长时间未输出。
select /*+ LOOKUP('table'='DUMR','async'='true', 'retry-predicate'='lookup_miss', 'output-mode'='ordered', 'retry-strategy'='fixed_delay','capacity'='200', 'fixed-delay'='5s', 'max-attempts'='200') */

1 Answers

目前不支持,lookup的hint需要依赖 LookupFunction的接口(Flink1.16之后引入)实现,可以先使用Flink JDBC Connector。