[
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 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.
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, 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 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.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
