Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Status

...

Page properties


Discussion thread

...

...

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-26762
https://lists.apache.org/thread/hljgzpg3y5tl9gw8ktf54mbc2pl8w61w
JIRA

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-

...

27530

Release1.16


Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

We will split this JIRA into two 3 tasks.

The first task: Ignore max buffers per channel when allocate buffer

...

Adding the new configuration : taskmanager.network.memory.max-overdraft-buffers-per-gate, the default value is 5~10?5.

The LocalBufferPool will be unavailable when the maxBuffersPerChannel is reached for this channel or availableMemorySegments.isEmpty or numberOfRequestedOverdraftMemorySegments > 0.

...

The third task: Compatible with LegacySource

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-27789

Since LegacySource does not have checkAvailable, LegacySource will use all overdraft buffers by default, this is not what we expected.

So we'll detect the LegacySource and set overdraft=0 on the Task containing the LegacySourcefor the SourceStreamTask.

Compatibility, Deprecation, and Migration Plan

...

  • Test for apply for overdraft buffer when overdraft buffer is sufficient
  • Test for apply for overdraft buffer when overdraft buffer is insufficient
  • Checkpoint Duration Benchmark for enable overdraft buffer 

Rejected Alternatives

After discussing, we decided to use overdraft-buffer instead of reserve-buffer. For details, please refer to the mail list.