Pavel Tupitsyn created IGNITE-25509:
---------------------------------------
Summary: Data Streamer ignores backpressure in flush timer
Key: IGNITE-25509
URL: https://issues.apache.org/jira/browse/IGNITE-25509
Project: Ignite
Issue Type: Bug
Components: data streamer ai3
Affects Versions: 3.0
Reporter: Pavel Tupitsyn
Assignee: Pavel Tupitsyn
Fix For: 3.1
When *StreamerSubscriber.flushBuffers* is invoked by *autoFlushInterval*, we do
not check active batches and always send everything.
As a result, in "slow consumer" scenario, active request count can grow without
limit, overloading the server further.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
