Hi!
I would like to know if there is any way I can use 2.4.0 Beam's Source API for Flink 1.4.0 runner? I have a custom unbounded source implemented for Flink runner but I can not find the documentation to use it for 2.x Beam SDK. Looks like it was only supported in 0.x SDK? Any help appreciated.
