-
Notifications
You must be signed in to change notification settings - Fork 4.3k
Prism windowed value coder #34830
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
Prism windowed value coder #34830
Conversation
Opened a bug for samza runner since the newly added test failed to run: #34831. |
b935f8b
to
d33ac3c
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Lgtm
Looks like flink will need that filtered out too. |
Flink runs fine previously. The current failure seems irrelevant to the change. Let me rerun the test one more time. |
Run Python Flink ValidatesRunner 3.12 |
Assigning reviewers. If you would like to opt out of this review, comment R: @jrmccluskey for label python. Available commands:
The PR bot will only process comments in the main thread (not review comments). |
fixes #34829