Hi All,

I'm new to Flink and have been testing version 1.14. (My issue also happens
in the previous version.)

When I run a job once it works fine. However when I submit it again and try
to run it I get a 'No suitable driver found' exception. The only way I have
found to rerun my job is to restart the cluster. What am I doing wrong?

I have set up my session cluster as per the example Docker Compose yml file
and my Maven job as per the quickstart archetype instructions.

The only additions are that I have included the Postgres driver in my
pom.xml and created a source derived from RichSourceFunction that opens a
postgres JDBC connection. The driver not found error stems opening the
connection.

A fuller description can be found at StackOverflow:
https://stackoverflow.com/questions/69437510/how-can-i-rerun-an-apache-flink-postgres-jdbc-job-without-getting-no-suitable-d

This seems like a Class Loader issue unloading the Postgres driver after
the first run and not allowing it to be loaded again for the second job
submission but not sure what the fix is.

Any help would be greatly appreciated.

Kind regards,
Dan

Reply via email to