[beam] branch master updated: [BEAM-9038] Fix typo for setting_global_window example

[pa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 93417ce  [BEAM-9038] Fix typo for setting_global_window example
     new 195bbf3  Merge pull request #14271 from [BEAM-9038] Fix typo for setting_global_window example
93417ce is described below

commit 93417cefab4f01f894c6e3ae1e7ae028eeb048c9
Author: Alexey Romanenko <ar...@gmail.com>
AuthorDate: Thu Mar 18 12:35:08 2021 +0100

    [BEAM-9038] Fix typo for setting_global_window example
---
 sdks/python/apache_beam/examples/snippets/snippets_test.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/examples/snippets/snippets_test.py b/sdks/python/apache_beam/examples/snippets/snippets_test.py
index d1a48e3..3ce6f1d 100644
--- a/sdks/python/apache_beam/examples/snippets/snippets_test.py
+++ b/sdks/python/apache_beam/examples/snippets/snippets_test.py
@@ -1240,11 +1240,11 @@ class CombineTest(unittest.TestCase):
           beam.Map(lambda x: beam.window.TimestampedValue(('k', x), x)))
       # [START setting_global_window]
       from apache_beam import window
-      session_windowed_items = (
+      global_windowed_items = (
           items | 'window' >> beam.WindowInto(window.GlobalWindows()))
       # [END setting_global_window]
       summed = (
-          session_windowed_items
+          global_windowed_items
           | 'group' >> beam.GroupByKey()
           | 'combine' >> beam.CombineValues(sum))
       unkeyed = summed | 'unkey' >> beam.Map(lambda x: x[1])