[
https://issues.apache.org/jira/browse/BEAM-11497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284860#comment-17284860
]
Beam JIRA Bot commented on BEAM-11497:
--------------------------------------
This issue is assigned but has not received an update in 30 days so it has been
labeled "stale-assigned". If you are still working on the issue, please give an
update and remove the label. If you are no longer working on the issue, please
unassign so someone else may work on it. In 7 days the issue will be
automatically unassigned.
> Division By Zero errors being thrown by new BQ Source
> -----------------------------------------------------
>
> Key: BEAM-11497
> URL: https://issues.apache.org/jira/browse/BEAM-11497
> Project: Beam
> Issue Type: Improvement
> Components: io-py-gcp, runner-dataflow
> Reporter: Pablo Estrada
> Assignee: Pablo Estrada
> Priority: P2
> Labels: stale-assigned
> Time Spent: 1h 20m
> Remaining Estimate: 0h
>
> Users are reporting issues with the BQ Source, where division by zero errors
> are being reported by Beam. A stack trace:
> {code:java}
> Log: [1] An exception was raised when trying to execute the workitem
> 2053702133423558223 : Traceback (most recent call last): File
> "/usr/local/lib/python3.7/site-packages/dataflow_worker/batchworker.py", line
> 649, in do_work work_executor.execute() File
> "/usr/local/lib/python3.7/site-packages/dataflow_worker/executor.py", line
> 179, in execute op.start() File "dataflow_worker/native_operations.py", line
> 38, in dataflow_worker.native_operations.NativeReadOperation.start File
> "dataflow_worker/native_operations.py", line 39, in
> dataflow_worker.native_operations.NativeReadOperation.start File
> "dataflow_worker/native_operations.py", line 44, in
> dataflow_worker.native_operations.NativeReadOperation.start File
> "dataflow_worker/native_operations.py", line 48, in
> dataflow_worker.native_operations.NativeReadOperation.start File
> "/usr/local/lib/python3.7/site-packages/dataflow_worker/workercustomsources.py",
> line 69, in iter self._source.start_position, self._source.stop_position)
> File
> "/usr/local/lib/python3.7/site-packages/apache_beam/io/concat_source.py",
> line 78, in get_range_tracker start_position, stop_position,
> self._source_bundles) File
> "/usr/local/lib/python3.7/site-packages/apache_beam/io/concat_source.py",
> line 131, in init
> self._compute_cumulative_weights(source_bundles[start[0]:last]) + [1] * File
> "/usr/local/lib/python3.7/site-packages/apache_beam/io/concat_source.py",
> line 154, in _compute_cumulative_weights running_total.append(max(min_diff,
> min(1, running_total[-1] + w / total))) ZeroDivisionError: flo
> {code}
>
> I am suspecting this issue: https://issues.apache.org/jira/browse/BEAM-2716
> [|https://issues.apache.org/jira/secure/AddComment!default.jspa?id=13341887]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
