[
https://issues.apache.org/jira/browse/BEAM-11620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263693#comment-17263693
]
Mátyás Manninger commented on BEAM-11620:
-----------------------------------------
Most definitely if I can understand why the values get converted to Duration
and how to run and test the project locally. The guides the the codebase should
help with that. Otherwise the actual fix is easy enough.
> PeriodicImpulse uses unspecified / operator on Durations
> --------------------------------------------------------
>
> Key: BEAM-11620
> URL: https://issues.apache.org/jira/browse/BEAM-11620
> Project: Beam
> Issue Type: Bug
> Components: sdk-py-core
> Affects Versions: 2.26.0, 2.27.0
> Reporter: Mátyás Manninger
> Priority: P2
>
> In the periodicsequence.py on line 42 there is a division which throws the
> following error:
> {code:python}
> File
> "/home/user/.virtualenvs/dflowenv/lib/python3.8/site-packages/apache_beam/transforms/periodicsequence.py",
> line 42, in initial_restriction
> total_outputs = math.ceil((end - start) / interval)
> TypeError: unsupported operand type(s) for /: 'Duration' and 'Duration'
> [while running 'read/periodic_impulse/GenSequence/PairWithRestriction']
> {code}
> Here is the code segment that generated this error:
> {code:python}
> class BigQuerySideinputPI(beam.PTransform): def __init__(self, query,
> refresh_interval = 86400):
> super(BigQuerySideinputPI, self).__init__()
> self.query = query
> self.refresh_interval = refresh_interval def expand(self, pcoll):
> return (
> pcoll
> | 'periodic_impulse' >>
> PeriodicImpulse(fire_interval=self.refresh_interval, apply_windowing=True)
> | 'inject_query' >> beam.Map(lambda x: self.query)
> | 'run_query' >> beam.ParDo(BigQueryRead())){code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
