Re:Re: Re: 关于flink sql自定义udf，eval方法被调用两次问题

感谢提供帮助 在 2021-08-16 11:31:11，"Qishang" 写道： >Hi >之前社区发过一个 JD 的解决方案，可以参考下[1]。 > >[1]: https://mp.weixin.qq.com/s/YluIj3vmebFmZjRbymKBZw > > > >黄志高 于2021年8月16日周一 上午11:04写道： > >> == Physical Execution Plan == >> >> Stage 1 : Data Source >> >> content : Source: TableSourceScan(table=[

Re: Re: 关于flink sql自定义udf，eval方法被调用两次问题

Hi 之前社区发过一个 JD 的解决方案，可以参考下[1]。 [1]: https://mp.weixin.qq.com/s/YluIj3vmebFmZjRbymKBZw 黄志高 于2021年8月16日周一 上午11:04写道： > == Physical Execution Plan == > > Stage 1 : Data Source > > content : Source: TableSourceScan(table=[[default_catalog, > default_database, test_kafka]], fields=[tz]) > > > > >

Re: 关于flink sql自定义udf，eval方法被调用两次问题

Hi. 应该是这个问题，https://issues.apache.org/jira/browse/FLINK-21573 打印一下执行计划和code gen 黄志高 于2021年8月15日周日 下午10:06写道： > hi all, > 各位大佬，有没有遇到过eval方法被调用两次问题，在我使用select * from (select tt1(tz) from > test_kafka) as t where tz is not null > 时，在eval方法进行入参打印时，发现eval方法被调用了两次，当我使用select * from (select