diff --git a/sdks/python/apache_beam/io/gcp/gcsio_integration_test.py b/sdks/python/apache_beam/io/gcp/gcsio_integration_test.py index d4a812bc698e..5aedb6c7908a 100644 --- a/sdks/python/apache_beam/io/gcp/gcsio_integration_test.py +++ b/sdks/python/apache_beam/io/gcp/gcsio_integration_test.py @@ -122,6 +122,7 @@ def test_copy_kms(self): self._test_copy("test_copy_kms", self.kms_key_name) @attr('IT') + @unittest.skip('BEAM-12352: enable once maxBytesRewrittenPerCall works again') def test_copy_rewrite_token(self): # Tests a multi-part copy (rewrite) operation. This is triggered by a # combination of 3 conditions: @@ -175,6 +176,7 @@ def test_copy_batch_kms(self): self._test_copy_batch("test_copy_batch_kms", self.kms_key_name) @attr('IT') + @unittest.skip('BEAM-12352: enable once maxBytesRewrittenPerCall works again') def test_copy_batch_rewrite_token(self): # Tests a multi-part copy (rewrite) operation. This is triggered by a # combination of 3 conditions: