清雨影 + 关注

清雨影 参与了问答:

集群模式下Flink如何确保同样的ID落在同一个节点上?

Flink on Yarn 集群里有几台机器组成的Yarn。能从消息中方便的提取一个用户ID。现在在处理流的过程中,希望同一个ID落到同一个机器上来提高效率。同时,希望partition by ID,...

“社区没人回答我就自己回答了吧…… .partitionCustom( new Partitioner[Long] { override def ...查看全部>
暂未提供

感兴趣or擅长的领域:

暂无
更多>
更多>