开发者社区 问答 正文

flinksql insert overwrite 报错 INSERT OVERWRITE requ

请问在flink 1.11.0文档[1]中发现可以使用时可以使用INSERTOVERWRITE... 尝试了一下,但是在执行语句"insert overwrite mysqlsink select a,cast(b as varchar) b from mySource"时报如下错误 Exception in thread "main" org.apache.flink.table.api.ValidationException: INSERT OVERWRITE requires JDBC:MySQL DynamicTableSink to implement SupportsOverwrite interface. 是得自定义connector吗,实现DynamicTableSink? [1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/insert.html#syntax*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-08 10:35:20 2143 分享 版权
1 条回答
写回答
取消 提交回答
  • 
    Database Upsert Grammar
    MySQL INSERT .. ON DUPLICATE KEY UPDATE ..
    PostgreSQL INSERT .. ON CONFLICT .. DO UPDATE SET ..
    
    MySQL connector 不支持 replace into, 用的是 on duplicate key update.
    *来自志愿者整理的flink邮件归档
    
    2021-12-08 11:11:49
    赞同 展开评论