[FLINK-21922] The method partition_by in Over doesn't work for expression dsl

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.13.0, 1.12.3
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Dian Fu
• Reporter: Dian Fu
• Created: 23/Mar/21 06:28
• Updated: 23/Mar/21 09:33
• Resolved: 23/Mar/21 09:33

Description

For the following example:

t = t_env.from_elements([(1, 1, "Hello")], ['a', 'b', 'c'])

result = t.over_window(
 Over.partition_by(t.c)
 .order_by("a")
 .preceding(expr.row_interval(2))
 .following(expr.CURRENT_ROW)
 .alias("w"))

It will throw the following exception:

org.apache.flink.api.python.shaded.py4j.Py4JException: Method partitionBy([class org.apache.flink.table.api.ApiExpression]) does not existorg.apache.flink.api.python.shaded.py4j.Py4JException: Method partitionBy([class org.apache.flink.table.api.ApiExpression]) does not exist at org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.getMethod(ReflectionEngine.java:318) at org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.getMethod(ReflectionEngine.java:339) at org.apache.flink.api.python.shaded.py4j.Gateway.invoke(Gateway.java:276) at org.apache.flink.api.python.shaded.py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) at org.apache.flink.api.python.shaded.py4j.commands.CallCommand.execute(CallCommand.java:79) at org.apache.flink.api.python.shaded.py4j.GatewayConnection.run(GatewayConnection.java:238) at java.lang.Thread.run(Thread.java:748)

Issue Links

• links to: GitHub Pull Request #15338