Re: flink sql实时计算UpsertStreamTableSink requires that Table has a full primary keys if it is updated

旧版 'connector.type' = 'jdbc'，新版 'connector' = 'jdbc'。 新旧区别，旧版根据查询决定key，新版你只需要定义了key就是upsert了，不需要查询符合一定要求。 Leonard Xu 于2020年12月7日周一 下午5:11写道： > Hi, > 你是不是没有订阅flink的用户邮件列表，所以有些邮件你看不到。 > 你可以发送任意内容的邮件到user-zh-subscr...@flink.apache.org user-zh-subscr...@flink.apache.org>

Re: flink sql实时计算UpsertStreamTableSink requires that Table has a full primary keys if it is updated

Hi, 你是不是没有订阅flink的用户邮件列表，所以有些邮件你看不到。 你可以发送任意内容的邮件到user-zh-subscr...@flink.apache.org 即可订阅用户邮件列表，订阅后邮件列表里大家的提问和回答你都可以看见了。 [1] https://flink.apache.org/zh/community.html > 在 2020年12月7日，16:50，Leonard Xu 写道： > > Hi, > >> 在 2020年12月7日，16:41，爱成绕指柔

Re: flink sql实时计算UpsertStreamTableSink requires that Table has a full primary keys if it is updated

Hi, > 在 2020年12月7日，16:41，爱成绕指柔 <1194803...@qq.com> 写道： > > Exception in thread "main" org.apache.flink.table.api.TableException: > UpsertStreamTableSink requires that Table has a full primary keys if it is > updated. 这个错误是在query 没法推断出主键，而 hbase sink 是一个upsert sink, 需要PK来实现upsert语义。