Please read the Basic API concepts guide in the documentation, in
particular
https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/api_concepts.html#lazy-evaluation.
The short answer is that main() is called on the client, while the sink
is executed on a taskmanager, i.e. in a
Hi
In my flink program, I want to send data to a server via MQTT protocol,
here is my code
https://gist.github.com/duytruong/d240958d2c4140b554b604cbef05edc7
The problem is it ran well on IntelliJ, but when submitted to cluster
(bin/start-local.sh), it could connect but failed to send data.
