Re: pyflink UDTF求助!

Xingbo Huang Thu, 18 Mar 2021 01:24:12 -0700

Hi,

经过排查，这个确实一个bug。问题出在没有正确处理在sub-query中使用的python udf。我已经创建JIRA[1]
来记录这个问题了。目前的workaroud方案是使用Table API。
具体可以参考下面的代码：
>>>
a = t_env.sql_query("""
SELECT
     hotime ,
     before_ta ,
     before_rssi ,
     after_ta ,
     after_rssil ,
     nb_tath ,
     nb_rssith ,
     train_and_predict(nb_tath, nb_rssith) predict
FROM source
""")
result = a.join_lateral("splitStr(predict) as (nbr_rssi, nbr_ta)")



[1] https://issues.apache.org/jira/browse/FLINK-21856

Best,
Xingbo

陈康 <844256...@qq.com> 于2021年3月18日周四 下午1:30写道：

> apache-flink 1.11.1
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

Re: pyflink UDTF求助!

回复