I had the exact same problem, running Flink version 1.19.1.
This is due to a bug in the python Flink library. In flink-connector-jdbc
v3.1, the JdbcOutputFormat
was renamed to RowJdbcOutputFormat
. This change has up till now not been implemented in the python Flink library.