Another data point folks: I've been able to run my simple test case with
Dataflow without issue, but Flink is still problematic.
Le dim. 7 juin 2020 à 18:48, Pradip Thachile a écrit :
> I've attached below some minimal sample code that reproduces this issue
> below. This work
(options=popts)
(
p
| "Do It" >> DummyPipeline()
)
job = p.run()
job.wait_until_finish()
if __name__ == "__main__":
main()
Le dim. 7 juin 2020 à 14:57, Pradip Thachile a écrit :
> Hey folks,
>
> I've got a Beam/Python pipeline that
Hey folks,
I've got a Beam/Python pipeline that works on the DirectRunner and now am
trying to run this on a local dev Flink cluster. Running this yields an
error out the gate around not being able to deserialize UnboundedSource (my
PubSub source). I'm not sure how to debug this and would love to
