hi ok,谢谢,懂了哈哈
在 2020-07-31 21:27:02,"Leonard Xu" <xbjt...@gmail.com> 写道: >Hello > >> 在 2020年7月31日,21:13,chenxuying <cxydeve...@163.com> 写道: >> >> 但是不太明白 "使用老的option参数还是需要根据query推导主键" 这里话是什么意思,需要怎么做 > >简单来讲,如果使用的是老版本(1.10)的option参数,代码执行的路径就和1.10版本一样的,1.10版本里是不支持定义 PRIMARY KEY 的, >是通过用户的query来决定写入的模式是upsert 还是 append , 你可以看下1.10的文档关于用query 推导 写入模式的文档[1], >如果已经在用1.11了,1.10的文档可以不用看的。 > >在1.10里经常出现query 推导不出 key 导致无法做upsert写入的case, 在1.11里通过支持定义 PRIMARY >KEY,不会再有类似问题.1.11的文档参考[2]。 > >祝好 >Leonard > >[1] >https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connect.html#jdbc-connector > ><https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connect.html#jdbc-connector> >[2] >https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/jdbc.html#how-to-create-a-jdbc-table > ><https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/jdbc.html#how-to-create-a-jdbc-table>