Hi Vinay,
I think the answer depends on what you want to achieve.
Subtasks of an operator are all executed by separate threads. Some of them
run in the same JVM others not. So if you want to share data across
subtasks being executed in the same process, you can use static variables
bound to the
Hi,
I am updating the DTO in one operator , so is it safe to use Thread Local
for it, I am taking care to clear it,
My confusion here is : is it required to create a Thread Local variable in
a streaming application, if the same piece of code is executed by different
threads, does flink handles
