Hi Phil,
>>> Is it a library missing from the Flink cluster? What would cause that
error?
In most cases, it implies the collision of jar dependencies.
flink-sql-connector-kafka jar should be enough to run the job and you may
need to check your classpath in the jobmanager to see if any other jars
t
I am running a Flink job locally using
python -m job.py
and it runs fine.
The job is:
calcul_count = t_env.execute_sql("""
SELECT
username,
COUNT(action) AS a_count
FROM kafka_logs
GROUP BY username
""")
with calcul_count.collect() as results:
for row in results:
print(row)
When i try to s
