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.

Sign up for GitHub

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

Already on GitHub? Sign in to your account

Jump to bottom

Batching with Timeout not working as expected #1675

Open
kohlisid opened this issue Apr 16, 2024 · 1 comment
Open

Batching with Timeout not working as expected #1675

kohlisid opened this issue Apr 16, 2024 · 1 comment
Assignees
@kohlisid
Labels
area/isb-jetstream Inter Step Buffer using JetStream bug Something isn't working
Milestone
1.3

Comments

@kohlisid
Copy link
Contributor

Describe the bug
When given a timeout as T, and batch size at B we want numaflow to return either B messages or read up until T whichever occurs first

Message from the maintainers:

Impacted by this bug? Give it a 馃憤. We often sort issues this way to know what to prioritize.

For quick help and support, join our slack channel.
@kohlisid kohlisid added the bug Something isn't working label Apr 16, 2024
@kohlisid kohlisid self-assigned this Apr 16, 2024
@kohlisid kohlisid added this to the 1.2 milestone Apr 16, 2024
@vigith vigith added the area/isb-jetstream Inter Step Buffer using JetStream label Apr 16, 2024
@whynowy
Copy link
Member

whynowy commented Apr 16, 2024

Somehow readTimeout is not documented in https://numaflow.numaproj.io/user-guide/reference/pipeline-tuning/, please add it as well.

@kohlisid kohlisid mentioned this issue Apr 16, 2024
Closed
@whynowy whynowy modified the milestones: 1.2, 1.3 Apr 22, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@kohlisid kohlisid

Labels
area/isb-jetstream Inter Step Buffer using JetStream bug Something isn't working
Projects
None yet
Milestone
1.3
Development

Successfully merging a pull request may close this issue.

feat: add batch reading for Jetstream kohlisid/numaflow
3 participants
@vigith @whynowy @kohlisid