You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2019/09/04 17:09:00 UTC
[jira] [Work logged] (BEAM-8088) PCollection boundedness should be
tracked and propagated
[ https://issues.apache.org/jira/browse/BEAM-8088?focusedWorklogId=306535&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-306535 ]
ASF GitHub Bot logged work on BEAM-8088:
----------------------------------------
Author: ASF GitHub Bot
Created on: 04/Sep/19 17:08
Start Date: 04/Sep/19 17:08
Worklog Time Spent: 10m
Work Description: chadrik commented on issue #9426: [BEAM-8088] Track PCollection boundedness in python sdk
URL: https://github.com/apache/beam/pull/9426#issuecomment-527995306
> Should we add a test for this in pipeline_test.py?
Done!
----------------------------------------------------------------
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:
users@infra.apache.org
Issue Time Tracking
-------------------
Worklog Id: (was: 306535)
Time Spent: 50m (was: 40m)
> 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
> Time Spent: 50m
> 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)