You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/04/25 18:46:27 UTC
[1/2] beam git commit: Fix in dataflow metrics
Repository: beam
Updated Branches:
refs/heads/master ed97edd2e -> 1d97bdffc
Fix in dataflow metrics
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/918c0a18
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/918c0a18
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/918c0a18
Branch: refs/heads/master
Commit: 918c0a1866805cec3a62605c6534fd6ed15126bb
Parents: ed97edd
Author: Pablo Estrada <pa...@google.com>
Authored: Tue Apr 25 09:36:27 2017 -0700
Committer: Ahmet Altay <al...@google.com>
Committed: Tue Apr 25 11:46:17 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/918c0a18/sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py b/sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py
index f90e3d5..fe0122f 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py
@@ -121,6 +121,9 @@ class DataflowMetrics(MetricResults):
# Now we create the MetricResult elements.
result = []
for metric_key, metric in metrics_by_name.iteritems():
+ if (metric['tentative'].scalar is None or
+ metric['committed'].scalar is None):
+ continue
attempted = metric['tentative'].scalar.integer_value
committed = metric['committed'].scalar.integer_value
result.append(MetricResult(metric_key,
[2/2] beam git commit: This closes #2676
Posted by al...@apache.org.
This closes #2676
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1d97bdff
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1d97bdff
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1d97bdff
Branch: refs/heads/master
Commit: 1d97bdffcdc88e9f30677fa44c8d2ba138f262cc
Parents: ed97edd 918c0a1
Author: Ahmet Altay <al...@google.com>
Authored: Tue Apr 25 11:46:19 2017 -0700
Committer: Ahmet Altay <al...@google.com>
Committed: Tue Apr 25 11:46:19 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------