You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by smq <37...@qq.com> on 2020/09/21 10:46:44 UTC
回复:消费kafka source反压
谢谢,多问一句,并行度为1的话,keyby算子加上keydstate对性能影响大吗
---原始邮件---
发件人: "Benchao Li"<libenchao@apache.org>
发送时间: 2020年9月21日(周一) 下午4:39
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: 消费kafka source反压
这种反压一般是下游反压过来的,可以检查下最后一个反压的算子,那个才是处理能力的瓶颈。
smq <374060171@qq.com> 于2020年9月21日周一 下午2:08写道:
>
> 大家好,在测试flink消费速率时,发现数据处理比较慢,大概一个task每秒处理1000条左右,经过查看UI界面,发现读取kafka数据源这块source反压达到1,请问有这方面经验吗?
--
Best,
Benchao Li
Re: 消费kafka source反压
Posted by Benchao Li <li...@apache.org>.
这个性能影响指的是跟那种情况进行对比呢?
smq <37...@qq.com> 于2020年9月21日周一 下午6:49写道:
> 谢谢,多问一句,并行度为1的话,keyby算子加上keydstate对性能影响大吗
>
>
>
> ---原始邮件---
> 发件人: "Benchao Li"<libenchao@apache.org>
> 发送时间: 2020年9月21日(周一) 下午4:39
> 收件人: "user-zh"<user-zh@flink.apache.org>;
> 主题: Re: 消费kafka source反压
>
>
> 这种反压一般是下游反压过来的,可以检查下最后一个反压的算子,那个才是处理能力的瓶颈。
>
> smq <374060171@qq.com> 于2020年9月21日周一 下午2:08写道:
>
> >
> >
> 大家好,在测试flink消费速率时,发现数据处理比较慢,大概一个task每秒处理1000条左右,经过查看UI界面,发现读取kafka数据源这块source反压达到1,请问有这方面经验吗?
>
>
>
> --
>
> Best,
> Benchao Li
--
Best,
Benchao Li