[ https://issues.apache.org/jira/browse/BEAM-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kyoungha Min updated BEAM-9325: ------------------------------- Description: org.apache.beam.sdk.util.UnownedInput/OutputStream currently do not override `read(byte[], int, int)` and `write(byte[], int, int)` and as a result, it is reading and writing 1 byte at a time. The throughput is too low (it is slower than writing to my HDD), and I believe it was not intended. was: org.apache.beam.sdk.util.UnownedInput/OutputStream currently do not override `read(byte[], int, int)` and `write(byte[], int, int)` and as a result, it is reading and writing 1 byte at a time by calling synchronized method every time. The throughput is too low (it is slower than writing to my HDD), and I believe it was not intended. > UnownedInput/OutputStream not overriding array method. > ------------------------------------------------------ > > Key: BEAM-9325 > URL: https://issues.apache.org/jira/browse/BEAM-9325 > Project: Beam > Issue Type: Wish > Components: sdk-java-core > Reporter: Kyoungha Min > Priority: Minor > Original Estimate: 1m > Remaining Estimate: 1m > > org.apache.beam.sdk.util.UnownedInput/OutputStream currently do not override > `read(byte[], int, int)` and `write(byte[], int, int)` and as a result, it is > reading and writing 1 byte at a time. > The throughput is too low (it is slower than writing to my HDD), and I > believe it was not intended. > -- This message was sent by Atlassian Jira (v8.3.4#803005)