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)
