Skip to content

Commit a66c472

Browse files
committed
address comment
1 parent c7afb24 commit a66c472

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sdks/java/core/src/main/java/org/apache/beam/sdk/util/StreamUtils.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,8 @@ public static byte[] getBytesWithoutClosing(InputStream stream) throws IOExcepti
6868
if (initialReadSize == -1) {
6969
return new byte[0];
7070
}
71-
int nextChar = stream.read();
72-
if (nextChar == -1) {
71+
int nextByte = stream.read();
72+
if (nextByte == -1) {
7373
if (initialReadSize == available) {
7474
// Available reflected the full buffer and we copied directly to the
7575
// right size.
@@ -79,7 +79,7 @@ public static byte[] getBytesWithoutClosing(InputStream stream) throws IOExcepti
7979
}
8080
outputStream = new ByteArrayOutputStream();
8181
outputStream.write(initialBuffer, 0, initialReadSize);
82-
outputStream.write(nextChar);
82+
outputStream.write(nextByte);
8383
} else {
8484
outputStream = new ByteArrayOutputStream();
8585
}

0 commit comments

Comments
 (0)