You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/03/02 02:09:00 UTC
[jira] [Closed] (FLINK-25216) test_sliding_group_window_over_proctime failed with "IndexError: list index out of range"
[ https://issues.apache.org/jira/browse/FLINK-25216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Huang Xingbo closed FLINK-25216.
--------------------------------
Resolution: Cannot Reproduce
Considering that this failure case has not appeared for several months, and it is difficult to reproduce locally, I will temporarily close it. If it occurs again, I will reopen this issue
> test_sliding_group_window_over_proctime failed with "IndexError: list index out of range"
> -----------------------------------------------------------------------------------------
>
> Key: FLINK-25216
> URL: https://issues.apache.org/jira/browse/FLINK-25216
> Project: Flink
> Issue Type: Bug
> Components: API / Python, Tests
> Affects Versions: 1.15.0
> Reporter: Dian Fu
> Assignee: Huang Xingbo
> Priority: Critical
> Labels: test-stability
> Fix For: 1.15.0
>
>
> {code}
> self = <pyflink.table.tests.test_pandas_udaf.StreamPandasUDAFITTests testMethod=test_sliding_group_window_over_proctime>
> Dec 06 03:10:43
> Dec 06 03:10:43 def test_sliding_group_window_over_proctime(self):
> Dec 06 03:10:43 self.t_env.get_config().get_configuration().set_string("parallelism.default", "1")
> Dec 06 03:10:43 from pyflink.table.window import Slide
> Dec 06 03:10:43 self.t_env.register_function("mean_udaf", mean_udaf)
> Dec 06 03:10:43
> Dec 06 03:10:43 source_table = """
> Dec 06 03:10:43 create table source_table(
> Dec 06 03:10:43 a INT,
> Dec 06 03:10:43 proctime as PROCTIME()
> Dec 06 03:10:43 ) with(
> Dec 06 03:10:43 'connector' = 'datagen',
> Dec 06 03:10:43 'rows-per-second' = '1',
> Dec 06 03:10:43 'fields.a.kind' = 'sequence',
> Dec 06 03:10:43 'fields.a.start' = '1',
> Dec 06 03:10:43 'fields.a.end' = '10'
> Dec 06 03:10:43 )
> Dec 06 03:10:43 """
> Dec 06 03:10:43 self.t_env.execute_sql(source_table)
> Dec 06 03:10:43 t = self.t_env.from_path("source_table")
> Dec 06 03:10:43 iterator = t.select("a, proctime") \
> Dec 06 03:10:43 .window(Slide.over("1.seconds").every("1.seconds").on("proctime").alias("w")) \
> Dec 06 03:10:43 .group_by("a, w") \
> Dec 06 03:10:43 .select("mean_udaf(a) as b, w.start").execute().collect()
> Dec 06 03:10:43 result = [i for i in iterator]
> Dec 06 03:10:43 # if the WindowAssigner.isEventTime() does not return false,
> Dec 06 03:10:43 # the w.start would be 1970-01-01
> Dec 06 03:10:43 # TODO: After fixing the TimeZone problem of window with processing time (will be fixed in
> Dec 06 03:10:43 # FLIP-162), we should replace it with a more accurate assertion.
> Dec 06 03:10:43 > self.assertTrue(result[0][1].year > 1970)
> Dec 06 03:10:43 E IndexError: list index out of range
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=27569&view=logs&j=3e4dd1a2-fe2f-5e5d-a581-48087e718d53&t=b4612f28-e3b5-5853-8a8b-610ae894217a&l=21780
--
This message was sent by Atlassian Jira
(v8.20.1#820001)