One thing needs to note is that the old connectors are still in the release-1.11/release-1.12 jars. So the old option still works but with the old connector codes.
You may need to find the root cause why the new options do not work, maybe some stack trace here ? abelm <abele.ma...@outlook.com> 于2020年12月10日周四 下午10:54写道： > 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/ >
