Spongebob created FLINK-25502:
---------------------------------
Summary: eval method of Flink ScalerFunction only run one time
Key: FLINK-25502
URL: https://issues.apache.org/jira/browse/FLINK-25502
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Affects Versions: 1.14.2
Reporter: Spongebob
assume that there is one scalerFunction named `id` which's eval method takes no
arguments and return increasing int value on each calling. Now I found that
when I call `id()` function in FlinkSQL that has 3 rows , the eval method only
was called one time so I got the same id value for each row. The sql likes
'SELECT f0, id() FROM T'.
So I decided to define one argument on `eval` method. When I execute sql
'SELECT f0, id(1) FROM T' I got the same id value still. But when I execute sql
'SELECT f0, id(f0) FROM T' then I could get the correct id value, because the
eval method was called by three times now.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
