[beam] branch master updated: Minor: fix typo

[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 d5eca31b440 Minor: fix typo
     new f63415ada0e Merge pull request #17516 from Minor: fix typo in FnApiRunner log statement
d5eca31b440 is described below

commit d5eca31b44044f98eedcb8988e013934547b73f4
Author: Ilion Beyst <il...@gmail.com>
AuthorDate: Sat Apr 30 14:41:25 2022 +0200

    Minor: fix typo
---
 .../python/apache_beam/runners/portability/fn_api_runner/fn_runner.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py b/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py
index 6609e500734..b7bd32d3ec7 100644
--- a/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py
+++ b/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py
@@ -387,8 +387,8 @@ class FnApiRunner(runner.PipelineRunner):
         while len(runner_execution_context.queues.ready_inputs) > 0:
           _LOGGER.debug(
               "Remaining ready bundles: %s\n"
-              "\tWatermark pending bunbles: %s\n"
-              "\tTime pending bunbles: %s",
+              "\tWatermark pending bundles: %s\n"
+              "\tTime pending bundles: %s",
               len(runner_execution_context.queues.ready_inputs),
               len(runner_execution_context.queues.watermark_pending_inputs),
               len(runner_execution_context.queues.time_pending_inputs))