You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Jan Lukavský (Jira)" <ji...@apache.org> on 2022/01/12 08:22:00 UTC

[jira] [Commented] (BEAM-10072) RequiresTimeSortedInput not working for DoFns without state

    [ https://issues.apache.org/jira/browse/BEAM-10072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474356#comment-17474356 ] 

Jan Lukavský commented on BEAM-10072:
-------------------------------------

It would be good to fix this. It is minor issue, because the documentation is currently aligned with the behavior, though the behavior could be improved. It might make sense to consume time-sorted input from stateless DoFn in certain corner cases. I'll leave this open for now. We might fix it if there is a demand.

> RequiresTimeSortedInput not working for DoFns without state
> -----------------------------------------------------------
>
>                 Key: BEAM-10072
>                 URL: https://issues.apache.org/jira/browse/BEAM-10072
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-core
>    Affects Versions: 2.20.0, 2.21.0, 2.22.0
>            Reporter: Jan Lukavský
>            Priority: P3
>          Time Spent: 2.5h
>  Remaining Estimate: 0h
>
> When DoFn annotated with `@RequiresTimeSortedInput` doesn't have a `StateSpec`, the ordering might break.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)