t;, and reflecting the ratio as
> backpressure if not affect theperformance.
>
> Best,
> Zhijiang
>
>
> ----------
> From:Piotr Nowojski
> Send Time:2019年1月4日(星期五) 17:01
> To:dev
> Subject:Re: [DISCUSS] Detection
reflecting the ratio as
backpressure if not affect theperformance.
Best,
Zhijiang
--
From:Piotr Nowojski
Send Time:2019年1月4日(星期五) 17:01
To:dev
Subject:Re: [DISCUSS] Detection Flink Backpressure
Hi,
In that case I think instead o
at causes the backpressure.
>>>>>
>>>>> However, currently we think that the InputBufferPoolUsage and
>>> OutputBufferPoolUsage requires some modification to be more accurate:
>>>>> 1. When there are multiple inputs or outputs, the
&g
e pre-allocate logic in the
>> receiver side, the InputBufferPoolUsage may be 100% even if the data have
>> not been received yet [2].
>>>>
>>>> We may need to address these problems before adopting the
>> InputBufferPoolUsage and OutputBufferPool
logic in the
>> receiver side, the InputBufferPoolUsage may be 100% even if the data have
>> not been received yet [2].
>> >>
>> >> We may need to address these problems before adopting the
>> InputBufferPoolUsage and OutputBufferPoolUsage as the backpr
gt; >> Besides, another similar thought is that we may also add new
> InputBufferUsage and OutputBufferUsage metrics to show (number of queued
> buffers / number of all buffers) instead.
> >>
> >>
> >> Best,
> >>Yun Gao
> >>
>
eued
>> buffers / number of all buffers) instead.
>>
>>
>> Best,
>>Yun Gao
>>
>>
>> [1] https://issues.apache.org/jira/browse/FLINK-10981
>> [2] https://issues.apache.org/jira/browse/FLINK-11082
>>
>>
>>
owse/FLINK-10981
[2] https://issues.apache.org/jira/browse/FLINK-11082
--
From:裴立平
Send Time:2019 Jan. 3 (Thu.) 13:39
To:dev
Subject:[DISCUSS] Detection Flink Backpressure
Recently I want to optimize the way to
he.org/jira/browse/FLINK-11082
--
From:裴立平
Send Time:2019 Jan. 3 (Thu.) 13:39
To:dev
Subject:[DISCUSS] Detection Flink Backpressure
Recently I want to optimize the way to find the positions where the
backpressures occured .
I rea
Recently I want to optimize the way to find the positions where the
backpressures occured .
I read some blogs about flink-backpressure and have a rough idea of it .
The method which Flink adopted is thread-stack-sample , it's heavy and
no-lasting .
The positions where backpressures occured are
10 matches
Mail list logo