情况:使用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') */