Re: Flink SQL and createRemoteEnvironment

2023-11-28 Thread sangram reddy
Hi, createRemoteEnvironment(...) methods have some obscure documentation. createRemoteEnvironment(String host,int port,String ... jarF

Flink SQL and createRemoteEnvironment

2023-11-27 Thread Oxlade, Dan
Hi, If I use StreamExecutionEnvironment.createRemoteEnvironment and then var tEnv = StreamTableEnvironment.create(env) from the resulting remote StreamExecutionEvironment will any sql executed using tEnv.executeSql be executed remotely inside the flink cluster? I'm seeing unexpected behavior wh