Hey,
I'm trying to use Beam on Flink with Python, and for some reason it insists
on using Flink 1.10 even though Beam's website states
<https://beam.apache.org/documentation/runners/flink/#beam-capability> that
v1.12 is already supported. Digging through the code, it seems there's
a hardcoded
limitation
<https://github.com/apache/beam/blob/0350f2efa3cd4cf994a102625e479fa06dc5a643/sdks/python/apache_beam/options/pipeline_options.py#L1216>
for
that in the Python SDK.

Is there a reason for that?

Thanks!
Nir

Reply via email to