ah, thanks, those doc pages are what I missed! On Mon, Feb 7, 2022 at 2:48 AM Dian Fu <dian0511...@gmail.com> wrote:
> The following code snippet should just work: > > ``` > from pyflink.datastream import StreamExecutionEnvironment > env = StreamExecutionEnvironment.get_execution_environment() > ``` > > It works both in local deployment and in flink clusters. > > You could refer to [1] on how to submit PyFlink jobs to a remote cluster. > > [1] > https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/cli/#submitting-pyflink-jobs > > Regards, > Dian > > > On Mon, Feb 7, 2022 at 12:09 AM nagi data monkey <nagidatamon...@gmail.com> > wrote: > >> Hi all, >> >> Anyone got a pyflink datastream job working? I think I'm having >> difficulty seeing a small flunk cluster I've set up in docker. I can't see >> any way that pyflink can pick up a Remote Execution Enviroment. This is the >> only 'compiling' code snippet I can find: >> >> from pyflink.datastream import StreamExecutionEnvironment >> env = StreamExecutionEnvironment.get_execution_environment() >> >> which at least allows me to run pyflink code, but not see any flink >> clusters etc. Any ideas how I'm meant to actually get a pyflink job running? >> >> TIA >> >
