关于flink的JDBCAppendTableSink不能往MySQL写入数据的问题

Question

1、使用继承RichSinkFunction类的方法，自定义写入MySQL，就可以完成数据写入MySQL的操作；
使用JDBCAppendTableSink.builder()这种方法的时候，没法写数据到MySQL。
2、

JDBCAppendTableSink sink = JDBCAppendTableSink.builder().setBatchSize(1)
                .setDrivername("com.mysql.jdbc.Driver")
                .setDBUrl("jdbc:mysql://localhost:3306/flink")
                .setUsername("root")
                .setPassword("123456")
                .setQuery(sql2)
                .setParameterTypes(types)
                .build();

Answer 1

不知道你这个问题是否已经解决, 如果还没有解决的话:

• 请看👉 ：《Flink 使用 JDBCAppendTableSink 操作 Mysql入门示例》 Java版
• 除此之外, 这篇博客: 聊聊flink基于JDBC的操作的source与JDBCAppendTableSink中的 flink使用mysql的source与sink 部分也许能够解决你的问题, 你可以仔细阅读以下内容或者直接跳转源博客中阅读:
  

  方法二

  注：目前的区别，addsource【自定义】 是流式     jdbc是batch

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^