You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Robert Burke (Jira)" <ji...@apache.org> on 2022/01/11 00:15:00 UTC

[jira] [Updated] (BEAM-13628) [Go SDK] Make Side input cache fit resolved semantics.

     [ https://issues.apache.org/jira/browse/BEAM-13628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Robert Burke updated BEAM-13628:
--------------------------------
    Status: Open  (was: Triage Needed)

> [Go SDK] Make Side input cache fit resolved semantics.
> ------------------------------------------------------
>
>                 Key: BEAM-13628
>                 URL: https://issues.apache.org/jira/browse/BEAM-13628
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-go
>    Affects Versions: 2.35.0
>            Reporter: Robert Burke
>            Priority: P2
>
> It's been determined the documentation in the proto was a a bit buggy WRT Side input semantics. Previous to https://github.com/apache/beam/pull/16474 it said state cache tokens are globally unique, however, in implementation and the original design they are unique WRT their associated StateKeys.
> This means the Go SDK's side input cache is broken as delivered, and can cause a correctness issue when there are multiple distinct side inputs.
> The correction will use the whole state key (which, for side inputs includes the transformID ,SideInputID) tuple (with a user key if it's a multimap side input)), along with the Runner provided token.



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