开发者社区> 问答> 正文

Flink keyby问题

Assassinxc 2019-04-09 09:38:56 376

Flink程序接入kafka源进行处理。
对流使用keyby分流,当流量大时,会发生反压,即使流量并没有很大。
但单独把keyby去掉后,就能够顶住很大的流量。
keyby的值使用UUID进行测试的,有正常进行分流。
keyby是否会对吞吐造成影响?该如何解决?

消息中间件 Kafka 流计算
分享到
取消 提交回答
全部回答(1)
  • 石权infinite
    2019-07-17 23:32:52

    keyby后,数据会根据key值发往下游的operator。建议你看下graph中哪个task产生了反压,是不是和IO相关。

    0 0
+ 订阅

构建可靠、高效、易扩展的技术基石

推荐文章
相似问题
推荐课程