清雨影_个人页
清雨影
文章
0
问答
4
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
暂无更多信息
-
提交了问题
2019-01-15
Flink 运行的时候出现 : Could not materialize checkpoint
-
提交了问题
2018-11-20
Flink on Yarn 出现 Container Removed 问题
-
回答了问题
2019-07-17
集群模式下Flink如何确保同样的ID落在同一个节点上？
社区没人回答我就自己回答了吧…….partitionCustom( new Partitioner[Long] { override def partition(key: Long, numPartitions: Int): Int = { math.abs(MurmurHash3.arrayHash(Bytes.toBytes(key))) % numPartitions } }, _.getVehicleId )赞0 踩0 评论0 -
提交了问题
2018-11-13
集群模式下Flink如何确保同样的ID落在同一个节点上？
滑动查看更多
暂无更多信息