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)