Re: flink 1.11 自定义RichFlatMapFunction中使用JdbcRowDataOutputFormat 写pgsql数据问题，RuntimeContext初始化问题，空指针或RuntimeContext未初始化，哪里用的不对！

2020-07-15 文章 jindy_liu
确实是这行导致的， 如果都重构了，那应该怎么用较好的？ 我需要知道每一行对应的是insert, update还是delete事件。 或者问题变一下，对于这种api，一般遵守什么规则，flink的版本兼容性会更好？ -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink 1.11 自定义RichFlatMapFunction中使用JdbcRowDataOutputFormat 写pgsql数据问题，RuntimeContext初始化问题，空指针或RuntimeContext未初始化，哪里用的不对！

2020-07-14 文章 Jark Wu
Hi， 从异常来看，应该是少了如下这一行： outputFormatStatus = JdbcRowDataOutputFormat.dynamicOutputFormatBuilder() .setJdbcOptions(jdbcOptions) .setFieldDataTypes(fieldDataTypes) .setJdbcDmlOptions(dmlOptions) .setJdbcExecutionOptions(JdbcExecutionOptions.builde

flink 1.11 自定义RichFlatMapFunction中使用JdbcRowDataOutputFormat 写pgsql数据问题，RuntimeContext初始化问题，空指针或RuntimeContext未初始化，哪里用的不对！

2020-07-14 文章 jindy_liu
代码，编译没问题，但运行的时候，RichFlatMapFunction在open的时候，JdbcRowDataOutputFormat.open会core，说RuntimeContext为空，如果去掉outputFormatStatus.setRuntimeContext(this.getRuntimeContext())，又会提示没有初始化？ 麻烦大佬帮看看，什么问题啊，是我哪里用的不对吗？ at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Caused