Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-9014

Update CachingShuffleBatchReader to record weights by size in bytes

Details

    • Improvement
    • Status: Resolved
    • P3
    • Resolution: Incomplete
    • None
    • 2.21.0
    • runner-dataflow
    • None

    Description

      Currently the CachingShuffleBatchReader caches based upon the number of batches and not the size of those batches. This task is about updating CachingShuffleBatchReader to cache based on the size of those batches.

      Attachments

        Issue Links

          Activity

            People

              tysonjh Tyson Hamilton
              lcwik Luke Cwik
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 1.5h
                  1.5h