diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-07-20 03:29:17 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-07-20 03:29:17 -0700 |
| commit | 1d724ab23755704f2e5058f9c81e1de134fb5fb0 (patch) | |
| tree | 84d68903b0f8c828c30a76d7e2111131c14e3edd /other/java/hdfs3 | |
| parent | 60d14a9800d8513ae0849a764d66ce80795dadbe (diff) | |
| download | seaweedfs-1d724ab23755704f2e5058f9c81e1de134fb5fb0.tar.xz seaweedfs-1d724ab23755704f2e5058f9c81e1de134fb5fb0.zip | |
hdfs: support read write chunk manifest
Diffstat (limited to 'other/java/hdfs3')
| -rw-r--r-- | other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedInputStream.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedInputStream.java b/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedInputStream.java index c26ad728f..10ec9b3cc 100644 --- a/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedInputStream.java +++ b/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedInputStream.java @@ -45,7 +45,7 @@ public class SeaweedInputStream extends FSInputStream { this.contentLength = SeaweedRead.totalSize(entry.getChunksList()); this.bufferSize = bufferSize; - this.visibleIntervalList = SeaweedRead.nonOverlappingVisibleIntervals(entry.getChunksList()); + this.visibleIntervalList = SeaweedRead.nonOverlappingVisibleIntervals(filerGrpcClient, entry.getChunksList()); LOG.debug("new path:{} entry:{} visibleIntervalList:{}", path, entry, visibleIntervalList); |