flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vinay Patil <vinay18.pa...@gmail.com>
Subject Thread Locals in Flink Streaming Application
Date Fri, 16 Sep 2016 15:50:02 GMT
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 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
here)

Can you please explain this to make it clear

Regards,
Vinay Patil

Mime
View raw message