Merge pull request #4531 from pabloem/log-sampler-deviation

[BEAM-2732] Logging deviation from sampling expectation.
apache · Feb 3, 2018 · 4f6415b · 4f6415b
2 parents 5e6520a + e832cfb
commit 4f6415b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sdks/python/apache_beam/runners/worker/statesampler_test.py b/sdks/python/apache_beam/runners/worker/statesampler_test.py
@@ -74,6 +74,8 @@ def test_basic_sampler(self):
       self.assertIn(counter.name, expected_counter_values)
       expected_value = expected_counter_values[counter.name]
       actual_value = counter.value()
+      deviation = float(abs(actual_value - expected_value)) / expected_value
+      logging.info('Sampling deviation from expectation: %f', deviation)
       self.assertGreater(actual_value, expected_value * 0.75)
       self.assertLess(actual_value, expected_value * 1.25)