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:22 UTC
[flink] branch master updated (5b42db8 -> 9516c94)
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5b42db8 [FLINK-12333][docs] Add documentation for all async operations through REST API
new 1210d8c [hotfix] [tests] Fix incomplete buffer reading in S3 test
new 9516c94 [hotfix] [tests] Unimplemented mock methods in RecoverableMultiPartUploadImplTest throw UnsupportedOperationException
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../fs/s3/common/writer/RecoverableMultiPartUploadImplTest.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
[flink] 01/02: [hotfix] [tests] Fix incomplete buffer reading in S3
test
Posted by se...@apache.org.
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 1210d8c4e138e445cb9aea302b86a77b801a8086
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Thu May 2 15:17:03 2019 +0200
[hotfix] [tests] Fix incomplete buffer reading in S3 test
---
.../flink/fs/s3/common/writer/RecoverableMultiPartUploadImplTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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 0194065..6b9f32e 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
@@ -20,6 +20,7 @@ package org.apache.flink.fs.s3.common.writer;
import org.apache.flink.fs.s3.common.utils.RefCountedBufferingFileStream;
import org.apache.flink.fs.s3.common.utils.RefCountedFile;
+import org.apache.flink.util.IOUtils;
import org.apache.flink.util.MathUtils;
import com.amazonaws.services.s3.model.CompleteMultipartUploadResult;
@@ -399,7 +400,7 @@ public class RecoverableMultiPartUploadImplTest {
private byte[] getFileContentBytes(File file, int length) throws IOException {
final byte[] content = new byte[length];
- new FileInputStream(file).read(content, 0, length);
+ IOUtils.readFully(new FileInputStream(file), content, 0, length);
return content;
}
[flink] 02/02: [hotfix] [tests] Unimplemented mock methods in
RecoverableMultiPartUploadImplTest throw UnsupportedOperationException
Posted by se...@apache.org.
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 {