[
https://issues.apache.org/jira/browse/BEAM-8088?focusedWorklogId=307035&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-307035
]
ASF GitHub Bot logged work on BEAM-8088:
----------------------------------------
Author: ASF GitHub Bot
Created on: 05/Sep/19 09:57
Start Date: 05/Sep/19 09:57
Worklog Time Spent: 10m
Work Description: mxm commented on pull request #9426: [BEAM-8088] Track
PCollection boundedness in python sdk
URL: https://github.com/apache/beam/pull/9426
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 307035)
Time Spent: 1h (was: 50m)
> PCollection boundedness should be tracked and propagated
> --------------------------------------------------------
>
> Key: BEAM-8088
> URL: https://issues.apache.org/jira/browse/BEAM-8088
> Project: Beam
> Issue Type: Improvement
> Components: sdk-py-core
> Reporter: Chad Dombrova
> Assignee: Chad Dombrova
> Priority: Major
> Fix For: 2.16.0
>
> Time Spent: 1h
> Remaining Estimate: 0h
>
> As far as I can tell Python does not care about boundedness of PCollections
> even in streaming mode, but external transforms _do_. In my ongoing effort
> to get PubsubIO external transforms working I discovered that I could not
> generate an unbounded write.
> My pipeline looks like this:
> {code:python}
> (
> pipe
> | 'PubSubInflow' >>
> external.pubsub.ReadFromPubSub(subscription=subscription,
> with_attributes=True)
> | 'PubSubOutflow' >>
> external.pubsub.WriteToPubSub(topic=OUTPUT_TOPIC, with_attributes=True)
> )
> {code}
> The PCollections returned from the external Read are Unbounded, as expected,
> but python is responsible for creating the intermediate PCollection, which is
> always Bounded, and thus external Write is always Bounded.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
