diff --git a/sdks/python/apache_beam/examples/snippets/transforms/elementwise/pardo.py b/sdks/python/apache_beam/examples/snippets/transforms/elementwise/pardo.py index c54d05e39911..fd8dca134d2d 100644 --- a/sdks/python/apache_beam/examples/snippets/transforms/elementwise/pardo.py +++ b/sdks/python/apache_beam/examples/snippets/transforms/elementwise/pardo.py @@ -96,7 +96,7 @@ def pardo_dofn_methods(test=None): class DoFnMethods(beam.DoFn): def __init__(self): print('__init__') - self.window = beam.window.GlobalWindow() + self.window = beam.transforms.window.GlobalWindow() def setup(self): print('setup') diff --git a/website/www/site/content/en/documentation/transforms/python/elementwise/pardo.md b/website/www/site/content/en/documentation/transforms/python/elementwise/pardo.md index efa64ab5d909..dc12acda1807 100644 --- a/website/www/site/content/en/documentation/transforms/python/elementwise/pardo.md +++ b/website/www/site/content/en/documentation/transforms/python/elementwise/pardo.md @@ -141,8 +141,6 @@ Output: > *Known issues:* > -> * [[BEAM-7885]](https://issues.apache.org/jira/browse/BEAM-7885) -> `DoFn.setup()` doesn't run for streaming jobs running in the `DirectRunner`. > * [[BEAM-7340]](https://issues.apache.org/jira/browse/BEAM-7340) > `DoFn.teardown()` metrics are lost.