[jira] [Created] (FLINK-25579) Py4JException: window([class org.apache.flink.table.api.SlideWithSizeAndSlide]) does not exist

["Darron Fuller (Jira)" <ji...@apache.org>]

Darron Fuller created FLINK-25579:
-------------------------------------

             Summary: Py4JException: window([class org.apache.flink.table.api.SlideWithSizeAndSlide]) does not exist
                 Key: FLINK-25579
                 URL: https://issues.apache.org/jira/browse/FLINK-25579
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.13.2
         Environment: Fails in AWS Kinesis Analytics Flink v1.13 and macOS 12.1 (21C52) Darwin 21.2.0, Python 3.8, Java(TM) SE Runtime Environment (build 1.8.0_311-b11)

  
            Reporter: Darron Fuller


CODE:
{quote}in_tbl = create_ingest_table()
result = in_tbl.select(col('*')).window(Slide.over(lit(2).hours).every(lit(15).minutes)) {quote}
STACK TRACE:
{quote}Traceback (most recent call last):
  File "/Users/dfulle424/projects/Comcast/DNSP-IA/streamedge/flink/table_api_agg_5m_window.py", line 53, in <module>
    main()
  File "/Users/dfulle424/projects/Comcast/DNSP-IA/streamedge/flink/table_api_agg_5m_window.py", line 47, in main
    result = in_tbl.group_by('name').select(col('*')).window(Slide.over(lit(2).hours).every(lit(15).minutes))
  File "/Users/dfulle424/anaconda3/envs/flink-python38/lib/python3.8/site-packages/pyflink/table/table.py", line 668, in window
    return GroupWindowedTable(self._j_table.window(window._java_window), self._t_env)
  File "/Users/dfulle424/anaconda3/envs/flink-python38/lib/python3.8/site-packages/py4j/java_gateway.py", line 1285, in __call__
    return_value = get_return_value(
  File "/Users/dfulle424/anaconda3/envs/flink-python38/lib/python3.8/site-packages/pyflink/util/exceptions.py", line 146, in deco
    return f(*a, **kw)
  File "/Users/dfulle424/anaconda3/envs/flink-python38/lib/python3.8/site-packages/py4j/protocol.py", line 330, in get_return_value
    raise Py4JError(
py4j.protocol.Py4JError: An error occurred while calling o33.window. Trace:
org.apache.flink.api.python.shaded.py4j.Py4JException: Method window([class org.apache.flink.table.api.SlideWithSizeAndSlide]) 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:326)
at org.apache.flink.api.python.shaded.py4j.Gateway.invoke(Gateway.java:274)
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){quote}



--
This message was sent by Atlassian Jira
(v8.20.1#820001)