退订
tiantingting5...@163.com
flink stream如何为每条数据生成自增主键？？时间戳貌似不行，同一时间戳可能会产生多条数据，无法区分数据的现后顺序。
tiantingting5...@163.com
Hello,
你试下 MD5(real_income_no) as rowkey 放在query的里层，最外层的group by直接用 rowkey试下， Flink
1.11 之后支持在 table里声明 PK, 1.11后就不用推导了。
祝好，
Leonard Xu
> 在 2020年7月1日，13:51，tiantingting5...@163.com 写道：
>
> MD5(real_income_no) as rowkey,
ception e) {
e.printStackTrace();
}
return prop;
});
}
}
tiantingting5...@163.com
发件人： Xintong Song
发送时间： 2020-05-08 15:56
收件人： user-zh
主题： Re: exception：beyond the 'PHYSICAL' memory limit
这个报错是 Flink 使用的内存超出了申请的 container 大小，被 yarn 杀掉了。因为 jvm 没有报 oom，所以应该只能是
na
-05-08 12:23:58.035]Container exited with a non-zero exit code 143.
tiantingting5...@163.com
