You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2020/11/23 13:00:25 UTC
[flink] 01/04: [FLINK-20145][checkpointing] Fix
FileBasedBufferIterator#read.
This is an automated email from the ASF dual-hosted git repository.
arvid pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 542fc946faae9f61ac8c75b9fc3fc7b7ce2962e3
Author: Arvid Heise <ar...@ververica.com>
AuthorDate: Thu Nov 19 12:51:28 2020 +0100
[FLINK-20145][checkpointing] Fix FileBasedBufferIterator#read.
---
.../java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java
index c7e1cd8..54e4fca 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java
@@ -77,7 +77,7 @@ public class FileBasedBufferIterator implements CloseableIterator<Buffer> {
private int read(byte[] buffer) {
int limit = Math.min(buffer.length, bytesToRead);
try {
- return stream.read(buffer, offset, limit);
+ return stream.read(buffer, 0, limit);
} catch (IOException e) {
throw new RuntimeException(e);
}