Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

changefeedccl: Do not block on file size based flushes #88395

Merged
merged 1 commit into from
Sep 23, 2022

Commits on Sep 22, 2022

  1. changefeedccl: Do not block on file size based flushes

    Prior to this change, cloud storage sink trigger
    file sized based flush whenever new row would
    would push the file size beyond configured threshold.
    
    This had the effect of singificantly reducing the throughput
    whenever such event occured -- no additional events could
    be added to cloud storage sink, while the previus flush was
    active.
    
    This is not necessary.  Cloud storage sink can trigger
    file based flushes asynchronously.  The only requirement
    is that if a real, non file based, flush arrives, or if we
    need to emit resolved timestamps, then we must wait for
    all of the active flush requests to complete.
    
    In addition, because every event added to cloud sink has
    associate allocation, which is released when file is written
    out, performing flushes asynchronously is safe with respect
    to memory usage and accounting.
    
    Release note (enterprise change): Changefeeds, using cloud
    storage sink, now have better throughput.
    Release justification: performance fix
    Yevgeniy Miretskiy committed Sep 22, 2022
    Configuration menu
    Copy the full SHA
    81f9932 View commit details
    Browse the repository at this point in the history