aboutsummaryrefslogtreecommitdiff
path: root/other/java/hdfs3/src
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-07-15 13:49:06 -0700
committerChris Lu <chris.lu@gmail.com>2020-07-15 13:49:06 -0700
commit86c81375462c874c34770bdd10df187075f10389 (patch)
treed6ba64d159a6f58c5519abd147f8afb12610deac /other/java/hdfs3/src
parent22f8aae02856bc9daf5f77a721444a5a83ecb48a (diff)
downloadseaweedfs-86c81375462c874c34770bdd10df187075f10389.tar.xz
seaweedfs-86c81375462c874c34770bdd10df187075f10389.zip
1.3.4
Diffstat (limited to 'other/java/hdfs3/src')
-rw-r--r--other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedOutputStream.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedOutputStream.java b/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedOutputStream.java
index 0dd094b55..3e0e89417 100644
--- a/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedOutputStream.java
+++ b/other/java/hdfs3/src/main/java/seaweed/hdfs/SeaweedOutputStream.java
@@ -17,6 +17,7 @@ import java.io.IOException;
import java.io.InterruptedIOException;
import java.io.OutputStream;
import java.util.Arrays;
+import java.util.Locale;
import java.util.concurrent.*;
import static seaweed.hdfs.SeaweedFileSystemStore.getParentDirectory;
@@ -108,7 +109,7 @@ public class SeaweedOutputStream extends OutputStream implements Syncable, Strea
// ensureCapacity
if (numberOfBytesToWrite > buffer.length - bufferIndex) {
int capacity = buffer.length;
- while(capacity-bufferIndex<numberOfBytesToWrite){
+ while (capacity - bufferIndex < numberOfBytesToWrite) {
capacity = capacity << 1;
}
if (capacity < 0) {