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
