Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21922

The method partition_by in Over doesn't work for expression dsl

    XMLWordPrintableJSON

    Details

      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)
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                dian.fu Dian Fu
                Reporter:
                dian.fu Dian Fu
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: