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
