回复：DML去重，translate时报错

题。 thanks, godfrey -- 发件人：JingsongLee 发送时间：2019年11月21日(星期四) 18:44 收件人：user-zh ; Jark Wu ; godfrey he (JIRA) 主　题：Re: DML去重，translate时报错 Hi 叶贤勋: 现在去重现在支持insert into select 语法。 问题在于你的这个SQL怎么没产出UniqueKey 这里面可能有blink-planner的bug。 CC

回复：DML去重，translate时报错

优化过程将 PROCTIME() 属性丢掉了，被认为只是一个普通的 timestamp 类型，不会翻译成 first row 的逻辑。我建了一个 issue 来 fix 这个问题。 thanks, godfrey -- 发件人：JingsongLee 发送时间：2019年11月21日(星期四) 18:44 收件人：user-zh ; Jark Wu ; godfrey he (JIRA) 主　题：Re: DML去重，translate时报错 Hi

Re: DML去重，translate时报错

Hi 叶贤勋: 现在去重现在支持insert into select 语法。 问题在于你的这个SQL怎么没产出UniqueKey 这里面可能有blink-planner的bug。 CC: @Jark Wu @godfrey he (JIRA) Best, Jingsong Lee -- From:叶贤勋 Send Time:2019年11月21日(星期四) 16:20 To:user-zh@flink.apache.org

DML去重，translate时报错

Hi 大家好： Flink版本1.9.0， SQL1： CREATE TABLE user_log ( user_id VARCHAR, item_id VARCHAR, category_id VARCHAR, behavior VARCHAR, ts TIMESTAMP ) WITH ( 'connector.type' = 'kafka', 'connector.version' = 'universal', 'connector.topic' = 'user_behavior',