You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2019/05/02 15:05:24 UTC

[flink] 02/02: [hotfix] [tests] Unimplemented mock methods in RecoverableMultiPartUploadImplTest throw UnsupportedOperationException

This is an automated email from the ASF dual-hosted git repository.

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 9516c94c3022eaebbf728f3ca62d844b029380e6
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Thu May 2 15:32:50 2019 +0200

    [hotfix] [tests] Unimplemented mock methods in RecoverableMultiPartUploadImplTest throw UnsupportedOperationException
---
 .../fs/s3/common/writer/RecoverableMultiPartUploadImplTest.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/writer/RecoverableMultiPartUploadImplTest.java b/flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/writer/RecoverableMultiPartUploadImplTest.java
index 6b9f32e..f01da88 100644
--- a/flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/writer/RecoverableMultiPartUploadImplTest.java
+++ b/flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/writer/RecoverableMultiPartUploadImplTest.java
@@ -375,12 +375,12 @@ public class RecoverableMultiPartUploadImplTest {
 
 		@Override
 		public boolean deleteObject(String key) throws IOException {
-			return false;
+			throw new UnsupportedOperationException();
 		}
 
 		@Override
 		public long getObject(String key, File targetLocation) throws IOException {
-			return 0;
+			throw new UnsupportedOperationException();
 		}
 
 		@Override
@@ -395,7 +395,7 @@ public class RecoverableMultiPartUploadImplTest {
 
 		@Override
 		public ObjectMetadata getObjectMetadata(String key) throws IOException {
-			return null;
+			throw new UnsupportedOperationException();
 		}
 
 		private byte[] getFileContentBytes(File file, int length) throws IOException {