diff --git a/sdks/python/apache_beam/io/textio.py b/sdks/python/apache_beam/io/textio.py index 0e7ea8ff2437..454fe4d69dea 100644 --- a/sdks/python/apache_beam/io/textio.py +++ b/sdks/python/apache_beam/io/textio.py @@ -871,6 +871,8 @@ def __init__( to exceed this value. This also tracks the uncompressed, not compressed, size of the shard. skip_if_empty: Don't write any shards if the PCollection is empty. + In case of an empty PCollection, this will still delete existing + files having same file path and not create new ones. """ self._sink = _TextSink(