Skip to content

[AURON #2446] Flush buffered data based on row count - #2447

Merged
slfan1989 merged 1 commit into
apache:masterfrom
zuston:fixbuffer
Jul 31, 2026
Merged

[AURON #2446] Flush buffered data based on row count#2447
slfan1989 merged 1 commit into
apache:masterfrom
zuston:fixbuffer

Conversation

@zuston

@zuston zuston commented Jul 30, 2026

Copy link
Copy Markdown
Member

Which issue does this PR close?

Closes #2446

this PR is to fix the incorrect flushing logic, that should be based on the row count rather than the bytes

Rationale for this change

Without this fix, the flushing will be triggered too frequently.

What changes are included in this PR?

Are there any user-facing changes?

How was this patch tested?

Was this patch authored or co-authored using generative AI tooling?

  • Yes
  • No

Generated-by: OpenAI Codex (GPT-5)

@slfan1989 slfan1989 self-assigned this Jul 31, 2026

@slfan1989 slfan1989 left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks for the contribution! compute_suggested_batch_size_for_output returns a row-count threshold, so comparing it with staging_num_rows fixes the unit mismatch. The regression test also clearly distinguishes the old byte-based behavior from the intended row-based behavior. The changes look good to me.

@slfan1989
slfan1989 merged commit 23fc4f5 into apache:master Jul 31, 2026
123 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

BufferedData compares staging memory bytes with a row-count threshold

2 participants