我的flink SQL 的时候使用了topN语法,在程序运行一段时间后出现了如下错误:
[flink-akka.actor.default-dispatcher-8695] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
Rank(strategy=[AppendFastStrategy], rankType=[ROW_NUMBER],
rankRange=[rankStart=1, rankEnd=1], partitionBy=[contact_id, service_no],
orderBy=[
Hi Guys,
I want to contribute to Apache Flink.
Would you please give me the permission as a contributor?
My JIRA ID is yutaochina.
2019-03-20
博彦科技股份有限公司
--上海泓智信息科技有限公司
地址:上海市长宁区天山路8号402室
邮编:200336
手机:15501079221
邮箱:hdxg1101300...@163.com,yuta...@beyondsoft.com
发件人:"hdxg1101300123"
发送时间:2019-