[
https://issues.apache.org/jira/browse/FLINK-21509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Zhong reassigned FLINK-21509:
---------------------------------
Assignee: Wei Zhong
> "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
> Assignee: Wei Zhong
> Priority: Major
> Labels: pull-request-available
>
> "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)
