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

Use typed sinks and sources for FnApiControlClientPoolService

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • P3
    • Resolution: Fixed
    • None
    • Not applicable
    • runner-core
    • None

    Description

      We operate with blocking queues directly when managing control clients with the FnApiControlClientPoolService. This makes interactions with the client pool difficult to understand. We should instead make client sources and sinks explicit.

      Attachments

        Issue Links

          is related to

          Improvement - An improvement or enhancement to an existing feature or task. BEAM-2889 Flink runs portable pipelines

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved
          links to

          Web Link GitHub Pull Request #5008

          Activity

            People

              bsidhom Ben Sidhom
              bsidhom Ben Sidhom
              Votes:
              0 Vote for this issue
              Watchers:
              1 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 - 2h 20m
                  2h 20m