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

Replace Flink StreamingImpulseSource with generic timer-based source

Details

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

    Description

      The StreamingImpulseSource is a Flink Runner specific transform for load tests. Now that timers are supported, we should look into whether a timer-based generator could generate the same load as the current source. This would allow us to remove the proprietary implementation.

      Attachments

        Activity

          People

            Unassigned Unassigned
            mxm Maximilian Michels
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: