Hi Andreas,
for me this looks like an error. The problem is that the Client does not
respect the global configuration file when you execute your program from
Java/IDE. There is also no way to specify a configuration file for the
RemoteEnvironment, unlike for the LocalEnvironment. I think this shou
Hello,
I want to execute a Job from Java on an already running instance of
Flink. I connect via the RemoteEnvironment. Everything goes fine, but
then I get an exception from akka telling me the payload size is exceeded:
15-07-16 17:47:27 [ERROR] Transient association error (association
remai