Details

    • New Feature
    • Status: Triage Needed
    • P2
    • Resolution: Implemented
    • None
    • 2.38.0
    • runner-py-interactive
    • None

    Description

      • Completes the package integration support fromĀ [BEAM-13973] Link Dataproc Flink master URLs to the InteractiveRunner when FlinkRunner is usedĀ #16904
      • Enables full support for Interactive Beam to create a Dataproc cluster when the underlying runner is a FlinkRunner
      • Sets the Interactive Environment clusters instance to the Interactive Beam global instance of clusters
      • Moves all constants related to Dataproc clusters into ib.clusters
      • Fixes an issue with checking for the recording size of a pipeline run that uses a GCS cache_root

      Attachments

        Issue Links

          Activity

            People

              victorhc Victor Chen
              victorhc Victor Chen
              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 - 13h 10m
                  13h 10m

                  Slack

                    Issue deployment