You are using a proprietary connector which only works on Dataflow. You
will have to use io.external.gcp.pubsub.ReadFromPubsub. PubSub support
is experimental from Python.
-Max
On 09.06.20 06:40, Pradip Thachile wrote:
> Quick update: this test code works just fine on Dataflow as well as the
> D
Quick update: this test code works just fine on Dataflow as well as the
DirectRunner. Looks like the FlinkRunner is problematic for some reason here.
On 2020/06/08 20:11:13, Pradip Thachile wrote:
> Hey folks,
>
> I posted this on the Flink user mailing list but didn't get any traction
> the
