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’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[prism] Support SortedTime input (java annotation & requirement) #33513

Closed
Tracked by #29650
lostluck opened this issue Jan 7, 2025 · 1 comment · Fixed by #33515
Closed
Tracked by #29650

[prism] Support SortedTime input (java annotation & requirement) #33513

lostluck opened this issue Jan 7, 2025 · 1 comment · Fixed by #33515
Assignees
@lostluck
Labels
go prism runners
Milestone
2.63.0 Release

Comments

@lostluck
Copy link
Contributor

lostluck commented Jan 7, 2025 •
edited
Loading

Support SortedTime input (java annotation & requirement), and enable the affected tests.
@lostluck lostluck mentioned this issue Jan 7, 2025
Open
@lostluck lostluck self-assigned this Jan 7, 2025
@lostluck
Copy link
Contributor Author

lostluck commented Jan 7, 2025

Pretty straightforward:

  1. Need to allow the requirement.
  2. Such transforms are easiest to deal with by adding a fusion break: Prism already sorts input elements by event time.

@lostluck lostluck mentioned this issue Jan 7, 2025
Merged
3 tasks
lostluck added a commit that referenced this issue Jan 7, 2025
@lostluck
[#33513][prism]Handle Time sorted requirement and drop late data. (#3…
6509e51 
…3515)
@github-actions github-actions bot added this to the 2.63.0 Release milestone Jan 7, 2025
jrmccluskey pushed a commit to jrmccluskey/beam that referenced this issue Jan 8, 2025
@lostluck @jrmccluskey
[apache#33513][prism]Handle Time sorted requirement and drop late dat…
f762cb2 
…a. (apache#33515)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@lostluck lostluck

Labels
go prism runners
Projects
None yet
Milestone
2.63.0 Release
Development

Successfully merging a pull request may close this issue.

[#33513][prism]Handle Time sorted requirement and drop late data. lostluck/beam
1 participant
@lostluck