Merge pull request #16413 from blais/master

apache · Jan 14, 2022 · 8724555 · 8724555
2 parents 0a220a1 + cb08343
commit 8724555
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/python/apache_beam/examples/wordcount.py b/sdks/python/apache_beam/examples/wordcount.py
@@ -84,7 +84,7 @@ def run(argv=None, save_main_session=True):
     counts = (
         lines
         | 'Split' >> (beam.ParDo(WordExtractingDoFn()).with_output_types(str))
-        | 'PairWIthOne' >> beam.Map(lambda x: (x, 1))
+        | 'PairWithOne' >> beam.Map(lambda x: (x, 1))
         | 'GroupAndSum' >> beam.CombinePerKey(sum))
 
     # Format the counts into a PCollection of strings.