Hi Jacob.
Based on your latest error message, it seems you're using an outdated
parameter 'connector.type' = 'jdbc'. You should use 'connector' = 'jdbc'
instead.
Please refer to the following documentation[1]
[1].
https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/table/jd
Hi Jacob,
It’s a little bit of guesswork …
The disappearing records remind me a bit of a peculiarity of Oracle, that each
(e.g. INSERT) statement is in an implicit transaction and hence needs to be
committed.
In Flink committing transaction happen together with the checkpoint cycle, i.e.
this
