Hello,
this problem is described in
https://issues.apache.org/jira/browse/FLINK-6689.
Basically, if you want to use the LocalFlinkMiniCluster you should use a
TestStreamEnvironment instead.
The RemoteStreamEnvironment only works with a proper Flink cluster.
Regards,
Chesnay
On 14.07.2017
Hi,
I am trying to upgrade my project from Flink 1.2 to 1.3 and getting problems
while trying to run Flink server from my Intellij project. The code
// Execute on the local Flink server - to test queariable state
def executeServer() : Unit = {
// We use a mini cluster here for sake of
