[jira] [Created] (BEAM-14498) Python sdk's PeriodicImpulse generates a bounded PCollection

["Yi Hu (Jira)" <ji...@apache.org>]

Yi Hu created BEAM-14498:
----------------------------

             Summary: Python sdk's PeriodicImpulse generates a bounded PCollection
                 Key: BEAM-14498
                 URL: https://issues.apache.org/jira/browse/BEAM-14498
             Project: Beam
          Issue Type: Bug
          Components: sdk-java-core
            Reporter: Yi Hu


See the dev mail list thread for details: https://lists.apache.org/thread/ps3m0jc0ngqp1y2s0mv2n6hxhvgkr3vw

PeriodicImpluse transform in Java sdk generates unbounded
PCollection; while in Python sdk it generates bounded PCollection. The
latter case may cause issues in streaming.

Per Cham: Note that the primary use-case of PeriodicImpulse (according to the design doc) was to
generate a fixed/bounded input that can slowly change over time but
changing over time dimension would make it unbounded. 

Seems like we need to make python PeriodicImpulse generates an unbounded pcoll, in  alignment with Java implementation, and also make sure that the change does not break the current implementation of its original use case (stream enrichment problem).



--
This message was sent by Atlassian Jira
(v8.20.7#820007)