Hi,
I am using apache-flink 1.19 and python 3.11. I have a very simple batch
job which registers a source table using CREATE TABLE … and output to a
sink table, another CREATE TABLE …. Before I output to sink table, I run a
dedup query
SELECT *
FROM (
SELECT *, ROW_NUMBER() OVER (PARTITION BY {partitionColStr} ORDER
BY procTime ASC) AS row_num
FROM input_table)
WHERE row_num = 1
When I run this query in my IDE, I am getting this error
py4j.protocol.Py4JJavaError: An error occurred while calling o18.sqlQuery.
: java.lang.NullPointerException: metadataHandlerProvider
Any idea what I may be missing?
Thank you in advance.
Antonio.
