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

Add support for timers in Spark portable streaming

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • runner-spark

    Description

      Add support for timely processing (using timers) for streaming on the portable Spark runner. Validates runner tests relying on timers (e.g. UsesTimersInParDo) should pass

      Attachments

        Activity

          People

            Unassigned Unassigned
            annaqin Anna Qin
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated: