I am attempting to run a Beam pipeline on a GCP Dataproc Flink cluster. I have followed the instructions at this repo <https://github.com/GoogleCloudDataproc/initialization-actions/tree/master/flink> to create a Flink cluster on Dataproc using an initialization action. However, the resulting cluster uses version 1.5.6 of Flink, and my project requires a more recent version (version 1.7, 1.8, or 1.9) for compatibility with Beam <https://beam.apache.org/documentation/runners/flink/>.
Inside of the flink.sh script in the linked repo, there is a line for installing Flink from a snapshot URL instead of apt <https://github.com/GoogleCloudDataproc/initialization-actions/blob/81e453d8f8a036e371e144d5103aaa38ecb2c679/flink/flink.sh#L53>. Is this the correct mechanism for installing a different version of Flink using the initialization script? If so, how is it meant to be used? Thank you in advance.
