Wei Zhong created FLINK-21509:
---------------------------------
Summary: "w.start" returns "1970-01-01" when used with Pandas UDAF after grouping by slide window with processing time
Key: FLINK-21509
URL:
https://issues.apache.org/jira/browse/FLINK-21509 Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.12.1, 1.13.0
Reporter: Wei Zhong
"w.start" returns "1970-01-01" when used with Pandas UDAF after grouping by slide window with processing time. Reproduce code:
{code:java}
t_env.get_config().get_configuration().set_string("parallelism.default", "1")
from pyflink.table.window import Slide
t_env.register_function("mean_udaf", mean_udaf)
source_table = """
create table source_table(
a INT,
proctime as PROCTIME()
) with(
'connector' = 'datagen',
'rows-per-second' = '1',
'fields.a.kind' = 'sequence',
'fields.a.start' = '1',
'fields.a.end' = '10'
)
"""
t_env.execute_sql(source_table)
t = t_env.from_path("source_table")
iterator = t.select("a, proctime") \
.window(Slide.over("1.seconds").every("1.seconds").on("proctime").alias("w")) \
.group_by("a, w") \
.select("mean_udaf(a) as b, w.start").execute().collect()
result = [i for i in iterator]
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)