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 this ?
Can we make use of open method to avoid ThreadLocal by initializing the
variable there, since the open will be called once per thread (correct me
Can you please explain this to make it clear