Mátyás Manninger created BEAM-11620:
---------------------------------------
Summary: 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.27.0, 2.26.0
Reporter: Mátyás Manninger
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)
