elderpinzon commented on issue #30449: URL: https://github.com/apache/beam/issues/30449#issuecomment-1972385974
As the error message suggests the issue is caused by a division by zero. I found a quick way to bypass this issue by modifying the following line: https://github.com/apache/beam/blob/master/sdks/python/apache_beam/runners/worker/opcounters.py#L225 As follows: ``` mean_element_size = self.producer_batch_converter.estimate_byte_size( windowed_batch.values) / batch_length if batch_length !=0 else 0 ``` I confirmed my test code above runs after this change and also confirmed that all the unit tests in that folder pass after the change (tried to run all tests in the `runners` folder but a bunch failed due to gcloud authentication issues) -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
