Skip to content
This repository was archived by the owner on Jan 24, 2024. It is now read-only.

If all partition messages are sent, cancel the delayed tasks to avoid full gc or oom - #1745

Closed
keyboardbobo wants to merge 1 commit into
streamnative:branch-2.9.2.24from
keyboardbobo:branch-2.9.2.24
Closed

If all partition messages are sent, cancel the delayed tasks to avoid full gc or oom#1745
keyboardbobo wants to merge 1 commit into
streamnative:branch-2.9.2.24from
keyboardbobo:branch-2.9.2.24

Conversation

@keyboardbobo

Copy link
Copy Markdown
Contributor

If all partition messages are sent, cancel the delayed tasks to avoid full gc or oom

Fixes #1739

Motivation

The request.timeout.ms setting is too large to cause broker full gc or oom.

Modifications

If all partition messages are sent, cancel the delayed tasks to avoid full gc or oom

Verifying this change

  • Make sure that the change passes the CI checks.

(Please pick either of the following options)

This change is a trivial rework / code cleanup without any test coverage.

(or)

This change is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

(example:)

  • Added integration tests for end-to-end deployment with large payloads (10MB)
  • Extended integration test for recovery after broker failure

Documentation

Check the box below.

Need to update docs?

  • doc-required

    (If you need help on updating docs, create a doc issue)

  • no-need-doc

    (Please explain why)

  • doc

    (If this PR contains doc changes)

If all tasks are sent, cancel the timer tasks to avoid full gc or oom
@CLAassistant

CLAassistant commented Mar 1, 2023

Copy link
Copy Markdown

CLA assistant check
All committers have signed the CLA.

@BewareMyPower

Copy link
Copy Markdown
Contributor

Could you sign the CLA first?

@keyboardbobo

Copy link
Copy Markdown
Contributor Author

Could you sign the CLA first?

done

@BewareMyPower

Copy link
Copy Markdown
Contributor

BTW, could you open PRs for master branch? I see the other PR (https://github.com/streamnative/kop/pull/1747/files) is also opened for branch-2.9.2.24, but the code is different for master.

@Demogorgon314

Copy link
Copy Markdown
Member

BTW, could you open PRs for master branch?

+1

@keyboardbobo

Copy link
Copy Markdown
Contributor Author

BTW, could you open PRs for master branch? I see the other PR (https://github.com/streamnative/kop/pull/1747/files) is also opened for branch-2.9.2.24, but the code is different for master.

here : #1749

Demogorgon314 added a commit to Demogorgon314/kop that referenced this pull request Apr 15, 2026
…reamnative#1749)

Fixes streamnative#1745

### Modifications

 increase timeout for transaction recovery test
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants