New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[BEAM-14545] Optimize copies in dataflow v1 shuffle reader. #17802
[BEAM-14545] Optimize copies in dataflow v1 shuffle reader. #17802
Conversation
Can one of the admins verify this patch? |
1 similar comment
Can one of the admins verify this patch? |
...worker/src/main/java/org/apache/beam/runners/dataflow/worker/ChunkingShuffleBatchReader.java
Outdated
Show resolved
Hide resolved
.../worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartitioningShuffleReader.java
Outdated
Show resolved
Hide resolved
...aflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ByteArrayReader.java
Outdated
Show resolved
Hide resolved
...ava/org/apache/beam/runners/dataflow/worker/util/common/worker/ByteArrayShufflePosition.java
Show resolved
Hide resolved
...r/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/ShuffleEntry.java
Outdated
Show resolved
Hide resolved
...r/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/ShuffleEntry.java
Outdated
Show resolved
Hide resolved
...low-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/TestShuffleReader.java
Outdated
Show resolved
Hide resolved
9a2e665
to
d250ab2
Compare
sdks/java/core/src/main/java/org/apache/beam/sdk/util/CoderUtils.java
Outdated
Show resolved
Hide resolved
Codecov Report
@@ Coverage Diff @@
## master #17802 +/- ##
==========================================
- Coverage 73.99% 73.99% -0.01%
==========================================
Files 695 703 +8
Lines 91829 92934 +1105
==========================================
+ Hits 67953 68769 +816
- Misses 22630 22899 +269
- Partials 1246 1266 +20
Flags with carried forward coverage won't be shown. Click here to find out more.
Continue to review full report at Codecov.
|
d250ab2
to
0640246
Compare
sorry for the delay on this, IntelliJ was really not cooperating recently and I kept getting sidetracked trying to make the CoderUtils change. |
…7802) * shuffle tuning * review cleanup
…7802) * shuffle tuning * review cleanup
The current implementation for reading from shuffle copies byte[]s out of the larger buffer returned from reading from shuffle. This changes it to instead wrap the large buffer with ByteStrings, avoiding copying them again.
R: @lukecwik
Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:
R: @username
).[BEAM-XXX] Fixes bug in ApproximateQuantiles
, where you replaceBEAM-XXX
with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.CHANGES.md
with noteworthy changes.See the Contributor Guide for more tips on how to make review process smoother.
To check the build health, please visit https://github.com/apache/beam/blob/master/.test-infra/BUILD_STATUS.md
GitHub Actions Tests Status (on master branch)
See CI.md for more information about GitHub Actions CI.