Skip to content

return closed window in the accumulator's EOF to trigger GC #219

@syayi

Description

@syayi

Currently EOF response uses latest watermark as the window end time but if there are no responses from the user it will be set to -1 which will not trigger GC on the numaflow core side instead we need to use the window that came from the close request.

Fixes this issue - numaproj/numaflow#3262

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions