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