Hi guoxb.
没有全部代码，我猜你 addSink() 走了两次，调试看下。
guoxb__...@sina.com 于2021年4月9日周五 下午2:36写道：
> hi：
>情景：
> 我在用flink通过FlinkKafkaConsumer消费kafka的数据并写入到mysql的时候，在sink端我继承
> RichSinkFunction ,并重写了open(),close()方法，以及实现了invoke(),方法
> 个人理解：
> 1. open()方法在程序启动的时候只走一次，我在该方法中初始化了数据库连接
>
hi：
情景：
我在用flink通过FlinkKafkaConsumer消费kafka的数据并写入到mysql的时候，在sink端我继承
RichSinkFunction ,并重写了open(),close()方法，以及实现了invoke(),方法
个人理解：
1. open()方法在程序启动的时候只走一次，我在该方法中初始化了数据库连接
2. close()方法在程序结束的时候也是只走一次
3. invoke()方法在获取到每一条数据走一次这个方法
实际情况及问题(env.setParallelism(1
