如何解决Apache Flink Postgres JDBC作业重跑提示No suitable driver found异常

问题根因 #

该问题是Java JDBC DriverManager的全局注册机制和Flink会话集群的作业类加载隔离机制冲突导致的，具体逻辑如下：

1. PostgreSQL驱动的核心类org.postgresql.Driver内部存在静态代码块，类被加载时会自动执行，将自身实例注册到JDK全局单例java.sql.DriverManager中。
2. Flink会话集群默认启用作业类加载隔离：每个提交的作业会创建独立的动态用户类加载器，用于加载作业Jar包内的所有依赖，作业运行结束后，该类加载器会被销毁回收，避免不同作业的依赖冲突。
3. 首次作业运行时：用户类加载器加载PostgreSQL驱动类，驱动正常注册到DriverManager，因此可以正常创建JDBC连接。
4. 作业结束后：加载驱动的用户类加载器被销毁，但DriverManager中已经注册的驱动实例引用仍然残留，该实例对应的类已经属于被回收的类加载器，实际上已经不可用。
5. 第二次提交作业时：新作业创建了新的用户类加载器，也加载了新的PostgreSQL驱动类，但你直接调用DriverManager.getConnection时，DriverManager只会遍历已注册的旧驱动实例，旧驱动因类加载器已销毁无法匹配PostgreSQL的JDBC URL，而新加载的驱动类没有触发静态注册逻辑，DriverManager中不存在对应实例，因此抛出No suitable driver found错误。

无需重启集群的解决方案 #

你可以根据场景选择以下任意一种方案解决：

• 主动触发驱动注册：在调用DriverManager.getConnection之前添加代码Class.forName("org.postgresql.Driver")，该代码会强制用当前作业的用户类加载器加载驱动类，触发静态注册逻辑，将新的驱动实例注册到DriverManager，即可正常获取连接。
• 将驱动放入集群公共类路径：将PostgreSQL驱动Jar包放到所有Flink节点的lib/目录下，驱动会被Flink集群的公共类加载器加载，生命周期和集群一致，所有作业都可以直接识别到已注册的驱动，不会出现类加载器销毁导致的驱动失效问题。
• 改用JDBC连接池创建连接：使用HikariCP等连接池组件创建JDBC连接，连接池会优先使用当前作业的类加载器加载驱动，不会依赖DriverManager的全局注册逻辑，从根本上避免该问题。

内容的提问来源于stack exchange，提问作者Dan