Hi! Thank you for the reply! I understand that the metadata syntax is only available as of 1.12, but I am indeed trying to use Flink 1.12.
Regarding the option for ignoring parse errors: I have already noticed from before that, according to the docs, even in Flink 1.11 (which is the version that the project was running on before), the option should be 'json.ignore-parse-errors', but for some strange reason, to set fail on missing field to false, I also only seemed to get it to work with 'format.fail-on-missing-field', instead of the 'json.fail-on-missing-field' option stated in the docs. For that reason, I feel like I might be doing something wrong in terms of dependencies, given that so many of my connector/format options seem to require old syntax instead of the newer one from Flink 1.11 and 1.12 to run. As a further example, you might notice in my original message that I'm also using 'connector.type' = 'kafka' instead of 'connector' = 'kafka', because for some reason that's the only version that worked. Genuinely not sure how I managed to create such a problem, so any further help would be appreciated. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
