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

SplittableParDoViaKeyedWorkItems sets another timer when receiving ProcessContinuation#STOP

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: runner-core, runner-direct
    • Labels:
      None

      Description

      HBaseIOTest#testReadingKeyRangeMiddleSDF consistently fails if SplittableParDoViaKeyedWorkItems sets the wake-up time to be the resume time when receiving a ProcessContinuation#STOP

      Why are we setting another timer to execute after STOP?

      Also, why is the direct runner failing to make progress with the timer if it is set in the past relative to the current process time?

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              lcwik Luke Cwik
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: