Hey all, We're working on getting the portability framework <https://beam.apache.org/contribute/portability/> plumbed through the Flink runner. The first iteration will likely only support batch and will be limited in its deployment flexibility, but hopefully it shouldn't be too painful to expand this.
We have the start of a tracking doc here: https://s.apache.org/portable-beam-on-flink. We've documented the general deployment strategy here: https://s.apache.org/portable-flink-runner-overview. Feel free to provide comments on the docs or jump in on any of the referenced bugs. -- -Ben