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

Posted to commits@beam.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/03 07:51:00 UTC

[jira] [Commented] (BEAM-2927) Python SDK support for portable side input

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

Aljoscha Krettek commented on BEAM-2927:
----------------------------------------

The problematic piece is this: https://github.com/apache/beam/blob/1f681bb1687aaa1ec23741e87f8622e6a4e59f7d/sdks/python/apache_beam/runners/worker/sdk_worker.py#L72

The python harness tries to create a state client that uses the control API descriptor when starting the worker. However, the worker harness should use the state API descriptor that it gets from the {{ProcessBundleDescriptor}} to access state and side inputs.

cc [~lcwik]

> Python SDK support for portable side input
> ------------------------------------------
>
>                 Key: BEAM-2927
>                 URL: https://issues.apache.org/jira/browse/BEAM-2927
>             Project: Beam
>          Issue Type: Sub-task
>          Components: sdk-py-core
>            Reporter: Henning Rohde
>            Assignee: Robert Bradshaw
>            Priority: Major
>              Labels: portability
>          Time Spent: 2h
>  Remaining Estimate: 0h
>




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)