Re: Using the flink CLI option --pyRequirements

2021-10-20 Thread Dian Fu
Hi Francis Conroy, Do you want to debug the PyFlink job submitted via `flink run`? There is documentation [1] on how to debug it via `PyCharm`. PS: It supports the loopback mode in PyFlink which is enabled in local deployment. That's when you execute the PyFlink jobs locally, e.g. when executing

Using the flink CLI option --pyRequirements

2021-10-18 Thread Francis Conroy
Hi, I'm trying to install some required modules by supplying a requirements file when submitting to the cluster and the CLI just seems to stall. I've built 1.15-SNAPSHOT@7578758fa8c84314b8b3206629b3afa9ff41b636 and have run the wordcount example, everything else seems to work, I just can't submit