[ 
https://issues.apache.org/jira/browse/FLINK-25332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460557#comment-17460557
 ] 

TongMeng commented on FLINK-25332:
----------------------------------

[~dianfu] OK,so if I want to filter the 0.0  result from my UDF what the insert 
sql should be like.

> When using Pyflink Table API, 'where' clause seems to work incorrectly
> ----------------------------------------------------------------------
>
>                 Key: FLINK-25332
>                 URL: https://issues.apache.org/jira/browse/FLINK-25332
>             Project: Flink
>          Issue Type: Bug
>          Components: API / Python
>    Affects Versions: 1.13.0
>         Environment: Python 3.6.9, Pyflink 1.13.0, kafka2.12-2.4.0
>            Reporter: TongMeng
>            Priority: Major
>         Attachments: sql_explain.txt
>
>
> The UDF I used just returns a float, the first four data it returns 1.0, 2.0, 
> 3.0 and 4.0, then it returns 0.0. I use 'where' in the sql to filter the 0.0 
> result. So the expected result I want to see in the kafka should be 1.0, 2.0, 
> 3.0 and 4.0. However kafka consumer gives four 0.0.
> The sql is as follow:
> "insert into algorithmsink select dt.my_result from(select udf1(a) AS 
> my_result from mysource) AS dt where dt.my_result > 0.0" (udf1 is my UDF)
> After I  removed the 'where dt.my_result > 0.0' part, it workd well. Kafka 
> gave 1.0, 2.0, 3.0, 4.0, 0.0, 0.0, 0.0……



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to