Flink tps 速度问题

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink tps 速度问题

haibin
hello,各位大佬:    
 
在做实时etl的时候,source(kafka)->map->filter->flatmap->map->sink(kafka)这样流程etl的时候,发现处理速度很慢,有什么好的方法提高处理速度。
   有25个作业同时消费同一个topic(32个分区),会不会有性能问题?



--
Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re: Flink tps 速度问题

Biao Liu
你好,建议自己先排查一下,把问题范围缩小,别人才好帮忙
可以看看 back pressure 具体慢在哪里,再具体分析

haibin <[hidden email]> 于2019年6月19日周三 上午5:50写道:

> hello,各位大佬:
>
>
> 在做实时etl的时候,source(kafka)->map->filter->flatmap->map->sink(kafka)这样流程etl的时候,发现处理速度很慢,有什么好的方法提高处理速度。
>    有25个作业同时消费同一个topic(32个分区),会不会有性能问题?
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/