This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from b06fb9d Minor cleanup of tests using TestStream. (#10188)
add 8b47a03 CachingShuffleBatchReader use bytes to limit size.
add 99f9f39 [BEAM-9014] CachingShuffleBatchReader use bytes to limit
cache size.
No new revisions were added by this update.
Summary of changes:
.../worker/ApplianceShuffleEntryReader.java | 6 +--
.../worker/ChunkingShuffleBatchReader.java | 8 ++-
.../common/worker/CachingShuffleBatchReader.java | 61 ++++++++++++++++++----
.../util/common/worker/ShuffleBatchReader.java | 5 +-
.../worker/BatchingShuffleEntryReaderTest.java | 18 ++++---
.../worker/CachingShuffleBatchReaderTest.java | 4 +-
6 files changed, 76 insertions(+), 26 deletions(-)
