TongMeng created FLINK-25332:
--------------------------------
Summary: 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: Table SQL / API
Affects Versions: 1.13.0
Environment: Python 3.6.9, Pyflink 1.13.0, kafka2.12-2.4.0
Reporter: TongMeng
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"
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)
