Hi Wouter,

1) Regarding the performance difference between Beam and PyFlink, I guess it’s 
because you are using an in-memory runner when running it locally in Beam. In 
that case, the code path is totally differently compared to running in a remote 
cluster.
2) Regarding to `flink run`, I’m surprising that it’s running locally. Could 
you submit a java job with similar commands to see how it runs?
3) Regarding to `flink run-application`, could you share the exception stack?

Regards,
Dian

> 2021年7月6日 下午4:58,Wouter Zorgdrager <zorgdrag...@gmail.com> 写道:
> 
> uses

Reply via email to