hi all,
各位大佬,有没有遇到过eval方法被调用两次问题,在我使用select * from (select tt1(tz) from
test_kafka) as t where tz is not null
时,在eval方法进行入参打印时,发现eval方法被调用了两次,当我使用select * from (select tt1(tz) from
test_kafka) as t这个sql时,不进行where tz is not null 操作,eval方法此时只会调用一次,如果将where tz is
not null 改成 where tz ='某一个具体值'此时eval方法也只会调用一次,一开始我以为是is not null 问题,我进行重写is not
null方法,发现eval方法还是调用两次,不过此时发现eval方法是在select tt1(tz) from
test_kafka这个阶段发生一次,第二次是在where tz is not
null执行后发生,虽然最后输出的结果不是双份,但是我认为eval方法执行两次,对效率有一定的影响,以下附件是我的代码截图,望各位大佬帮忙分析下,flink版本1.12