[ https://issues.apache.org/jira/browse/BEAM-14071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Anonymous updated BEAM-14071: ----------------------------- Status: Triage Needed (was: Resolved) > Enabling Flink on Dataproc for Interactive Beam > ----------------------------------------------- > > Key: BEAM-14071 > URL: https://issues.apache.org/jira/browse/BEAM-14071 > Project: Beam > Issue Type: New Feature > Components: runner-py-interactive > Reporter: Victor Chen > Assignee: Victor Chen > Priority: P2 > Fix For: 2.38.0 > > Time Spent: 13h 10m > Remaining Estimate: 0h > > - Completes the package integration support fromĀ [[BEAM-13973] Link Dataproc > Flink master URLs to the InteractiveRunner when FlinkRunner is usedĀ > #16904|https://github.com/apache/beam/pull/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 -- This message was sent by Atlassian Jira (v8.20.10#820010)