This is an automated email from the ASF dual-hosted git repository.
yhu 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 2fac45517cd Improve File IO Logging (#29485)
2fac45517cd is described below
commit 2fac45517cd65554323b3a26f989310c728a5741
Author: Svetak Sundhar <[email protected]>
AuthorDate: Tue Nov 21 14:41:42 2023 +0000
Improve File IO Logging (#29485)
* Create HealthcareUtils file with shared resources
* revert
* improve logging
* improve logging
* better error msg
* improve logging
---
sdks/python/apache_beam/io/fileio.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/io/fileio.py
b/sdks/python/apache_beam/io/fileio.py
index e671cfea079..c221e5bf73e 100644
--- a/sdks/python/apache_beam/io/fileio.py
+++ b/sdks/python/apache_beam/io/fileio.py
@@ -740,7 +740,9 @@ class _MoveTempFilesIntoFinalDestinationFn(beam.DoFn):
if len(orphaned_files) > 0:
_LOGGER.info(
- 'Some files may be left orphaned in the temporary folder: %s',
+ 'Some files may be left orphaned in the temporary folder: %s. '
+ 'This may be a result of insufficient permissions to delete'
+ 'these temp files.',
orphaned_files)
except BeamIOError as e:
_LOGGER.info('Exceptions when checking orphaned files: %s', e)
