diff --git a/sdks/python/apache_beam/options/pipeline_options.py b/sdks/python/apache_beam/options/pipeline_options.py index a7db5bfb0e71..fc0c9025dabd 100644 --- a/sdks/python/apache_beam/options/pipeline_options.py +++ b/sdks/python/apache_beam/options/pipeline_options.py @@ -1172,6 +1172,10 @@ def _handle_temp_and_staging_locations(self, validator): return [] # Both staging and temp locations are bad, try to use default bucket. else: + _LOGGER.warning( + "Both temp_location and staging_location are invalid. " + "Expected format is 'gs:///'. " + "Attempting to create a default GCS bucket.") default_bucket = self._create_default_gcs_bucket() if default_bucket is None: temp_errors.extend(staging_errors)