Hi, As you may have noticed, some of the contributors are working on enabling the Python support on Flink. The upcoming 2.8 release is going to include much of the functionality and we are now shifting gears to stability and performance.
There have been some basic fixes already (logging, memory leak) and at this point we see very low throughput in streaming mode. Improvements are in-flight: https://issues.apache.org/jira/browse/BEAM-5760 https://issues.apache.org/jira/browse/BEAM-5521 There has been discussion and preliminary work to improve support for testing as well (streaming mode). The Python SDK currently doesn't have any (open source) streaming connectors, but we have added a Flink native transform that can be used for testing: https://issues.apache.org/jira/browse/BEAM-5707 I'm starting this thread here so that it is easier for more folks to get involved and stay in sync. Thanks, Thomas
