Hi!
I put a quick summary into the wiki. For future reference.
https://cwiki.apache.org/confluence/display/FLINK/Variables+Closures+vs.+Broadcast+Variables
Greetings,
Stephan
On Mon, Apr 27, 2015 at 11:10 AM, Stephan Ewen wrote:
> Adding to Fabian's and Sebastian's answer:
>
>
> Variable in
Adding to Fabian's and Sebastian's answer:
Variable in Closure (global variable)
--
- Happens when you reference some variable in the program from a function.
The variable becomes part of the Function's closure.
- The variable is distributed w
You should also be aware that the value of a static variable is only
accessible within the same JVM.
Flink is a distributed system and runs in multiple JVMs. So if you set a
value in one JVM it is not visible in another JVM (on a different node).
In general, I would avoid to use static variables i
Hi Hung,
A broadcast variable can also refer to an intermediate result of a Flink
computation.
Best,
Sebastian
On 25.04.2015 21:10, HungChang wrote:
Hi,
What would be the difference between using global variable and broadcasting
it?
A toy example:
// Using global
{{...
private static int
