I'm trying to understand these pyflink error messa...
# troubleshootingd
David Bryson
08/07/2023, 5:28 PMI'm trying to understand these pyflink error messages, I got this error when using the standard getting started examples from this repository: https://github.com/aws-samples/pyflink-getting-started/tree/main/pyflink-examples
Copy code
py4j.protocol.Py4JError: An error occurred while calling z:org.apache.flink.table.api.Tumble.over. Trace:
org.apache.flink.api.python.shaded.py4j.Py4JException: Method over([class java.lang.String]) does not exist
at org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.getMethod(ReflectionEngine.java:321)
at org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.getMethod(ReflectionEngine.java:342)
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.base/java.lang.Thread.run(Thread.java:829)David Bryson
08/09/2023, 5:39 PMI came to learn this was syntax from an old version of flink python bindings
David Bryson
08/09/2023, 11:11 PMactually I can't solve this one
David Bryson
08/09/2023, 11:12 PM Copy code
189 result = proj_table \
190 .window(Tumble.over(lit(1).hour).on('event_time').alias("hourly_window")) \
191 .group_by(col('hourly_window'), col('id')) \
192 .select(col('id'), col('sensor'), col('hourly_window').end.alias('hour'))
193 result.print()